diff options
Diffstat (limited to 'pw_rpc/nanopb/server_reader_writer_test.cc')
| -rw-r--r-- | pw_rpc/nanopb/server_reader_writer_test.cc | 13 |
1 files changed, 7 insertions, 6 deletions
diff --git a/pw_rpc/nanopb/server_reader_writer_test.cc b/pw_rpc/nanopb/server_reader_writer_test.cc index e7b43e645..98a3b52bc 100644 --- a/pw_rpc/nanopb/server_reader_writer_test.cc +++ b/pw_rpc/nanopb/server_reader_writer_test.cc @@ -189,7 +189,8 @@ TEST(NanopbUnaryResponder, Open_ReturnsUsableResponder) { NanopbUnaryResponder<pw_rpc_test_TestResponse>::Open< TestService::TestUnaryRpc>(ctx.server, ctx.channel.id(), ctx.service); - responder.Finish({.value = 4321, .repeated_field = {}}); + ASSERT_EQ(OkStatus(), + responder.Finish({.value = 4321, .repeated_field = {}})); EXPECT_EQ(ctx.output.last_response<TestService::TestUnaryRpc>().value, 4321); EXPECT_EQ(ctx.output.last_status(), OkStatus()); @@ -202,8 +203,8 @@ TEST(NanopbServerWriter, Open_ReturnsUsableWriter) { TestService::TestServerStreamRpc>( ctx.server, ctx.channel.id(), ctx.service); - responder.Write({.chunk = {}, .number = 321}); - responder.Finish(); + ASSERT_EQ(OkStatus(), responder.Write({.chunk = {}, .number = 321})); + ASSERT_EQ(OkStatus(), responder.Finish()); EXPECT_EQ(ctx.output.last_response<TestService::TestServerStreamRpc>().number, 321u); @@ -218,7 +219,7 @@ TEST(NanopbServerReader, Open_ReturnsUsableReader) { Open<TestService::TestClientStreamRpc>( ctx.server, ctx.channel.id(), ctx.service); - responder.Finish({.chunk = {}, .number = 321}); + ASSERT_EQ(OkStatus(), responder.Finish({.chunk = {}, .number = 321})); EXPECT_EQ(ctx.output.last_response<TestService::TestClientStreamRpc>().number, 321u); @@ -232,8 +233,8 @@ TEST(NanopbServerReaderWriter, Open_ReturnsUsableReaderWriter) { Open<TestService::TestBidirectionalStreamRpc>( ctx.server, ctx.channel.id(), ctx.service); - responder.Write({.chunk = {}, .number = 321}); - responder.Finish(Status::NotFound()); + ASSERT_EQ(OkStatus(), responder.Write({.chunk = {}, .number = 321})); + ASSERT_EQ(OkStatus(), responder.Finish(Status::NotFound())); EXPECT_EQ(ctx.output.last_response<TestService::TestBidirectionalStreamRpc>() .number, |