Skip to content
Snippets Groups Projects
Commit 4d0fb5f1 authored by Craig Tiller's avatar Craig Tiller
Browse files

Fixup callers with new api

parent f8ac5d84
No related branches found
No related tags found
No related merge requests found
...@@ -106,7 +106,7 @@ class SubscriberTest : public ::testing::Test { ...@@ -106,7 +106,7 @@ class SubscriberTest : public ::testing::Test {
server_address_ << "localhost:" << port; server_address_ << "localhost:" << port;
ServerBuilder builder; ServerBuilder builder;
builder.AddPort(server_address_.str()); builder.AddPort(server_address_.str());
builder.RegisterService(service_.service()); builder.RegisterService(&service_);
server_ = builder.BuildAndStart(); server_ = builder.BuildAndStart();
channel_ = CreateChannel(server_address_.str(), ChannelArguments()); channel_ = CreateChannel(server_address_.str(), ChannelArguments());
......
...@@ -332,7 +332,7 @@ TEST_F(End2endTest, ResponseStream) { ...@@ -332,7 +332,7 @@ TEST_F(End2endTest, ResponseStream) {
EXPECT_EQ(response.message(), request.message() + "2"); EXPECT_EQ(response.message(), request.message() + "2");
EXPECT_FALSE(stream->Read(&response)); EXPECT_FALSE(stream->Read(&response));
Status s = stream->Wait(); Status s = stream->Finish();
EXPECT_TRUE(s.IsOk()); EXPECT_TRUE(s.IsOk());
delete stream; delete stream;
...@@ -366,7 +366,7 @@ TEST_F(End2endTest, BidiStream) { ...@@ -366,7 +366,7 @@ TEST_F(End2endTest, BidiStream) {
stream->WritesDone(); stream->WritesDone();
EXPECT_FALSE(stream->Read(&response)); EXPECT_FALSE(stream->Read(&response));
Status s = stream->Wait(); Status s = stream->Finish();
EXPECT_TRUE(s.IsOk()); EXPECT_TRUE(s.IsOk());
delete stream; delete stream;
...@@ -422,7 +422,7 @@ TEST_F(End2endTest, BadCredentials) { ...@@ -422,7 +422,7 @@ TEST_F(End2endTest, BadCredentials) {
ClientContext context2; ClientContext context2;
ClientReaderWriter<EchoRequest, EchoResponse>* stream = ClientReaderWriter<EchoRequest, EchoResponse>* stream =
stub->BidiStream(&context2); stub->BidiStream(&context2);
s = stream->Wait(); s = stream->Finish();
EXPECT_FALSE(s.IsOk()); EXPECT_FALSE(s.IsOk());
EXPECT_EQ(StatusCode::UNKNOWN, s.code()); EXPECT_EQ(StatusCode::UNKNOWN, s.code());
EXPECT_EQ("Rpc sent on a lame channel.", s.details()); EXPECT_EQ("Rpc sent on a lame channel.", s.details());
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment