Lines Matching refs:ServerRpcContextStreamingImpl
130 contexts_.emplace_back(new ServerRpcContextStreamingImpl( in AsyncQpsServerTest()
305 class ServerRpcContextStreamingImpl final : public ServerRpcContext { class in grpc::testing::AsyncQpsServerTest
307 ServerRpcContextStreamingImpl( in ServerRpcContextStreamingImpl() function in grpc::testing::AsyncQpsServerTest::ServerRpcContextStreamingImpl
314 next_state_(&ServerRpcContextStreamingImpl::request_done), in ServerRpcContextStreamingImpl()
320 ~ServerRpcContextStreamingImpl() override {} in ~ServerRpcContextStreamingImpl()
329 next_state_ = &ServerRpcContextStreamingImpl::request_done; in Reset()
338 next_state_ = &ServerRpcContextStreamingImpl::read_done; in request_done()
349 next_state_ = &ServerRpcContextStreamingImpl::write_done; in read_done()
353 next_state_ = &ServerRpcContextStreamingImpl::finish_done; in read_done()
361 next_state_ = &ServerRpcContextStreamingImpl::read_done; in write_done()
364 next_state_ = &ServerRpcContextStreamingImpl::finish_done; in write_done()
374 bool (ServerRpcContextStreamingImpl::*next_state_)(bool);