Function TEST_F

3rdparty/libprocess/src/tests/grpc_tests.cpp:128–149

This test verifies that a gRPC future is properly set once the given call is processed by the server.

// This test verifies that a gRPC future is properly set once the
// given call is processed by the server.
TEST_F(GRPCClientTest, Success)
{
  PingPongServer server;
  Try<client::Connection> connection = server.startup();
  ASSERT_SOME(connection);

  client::Runtime runtime;

  Future<Try<Pong, StatusError>> pong = runtime.call(
      connection.get(),
      GRPC_CLIENT_METHOD(PingPong, Send),
      Ping(),
      call_options());

  AWAIT_ASSERT_READY(pong);
  EXPECT_SOME(pong.get());

  runtime.terminate();
  AWAIT_ASSERT_READY(runtime.wait());

  ASSERT_SOME(server.shutdown());
}


// This test verifies that we can have multiple outstanding gRPC calls.