Searched refs:StreamingRPCState (Results 1 – 1 of 1) sorted by relevance
407 class StreamingRPCState : public UntypedStreamingRPCState {411 StreamingRPCState(std::unique_ptr<grpc::GenericClientAsyncReaderWriter> call, in StreamingRPCState() function420 ~StreamingRPCState() override { in ~StreamingRPCState()707 state_.reset(new StreamingRPCState<Response>(std::move(call), context_)); in CreateStreamingState()720 core::RefCountPtr<StreamingRPCState<Response>> state_ TF_GUARDED_BY(mu_);