Searched refs:ClientReader (Results 1 – 12 of 12) sorted by relevance
32 class ClientReader; variable93 friend class ::grpc::ClientReader;
76 class ClientReader; variable379 friend class ::grpc::ClientReader;
47 class ClientReader; variable250 friend class ::grpc::ClientReader;
164 static ClientReader<R>* Create(ChannelInterface* channel, in Create()167 return new ClientReader<R>(channel, method, context, request); in Create()176 class ClientReader final : public ClientReaderInterface<R> {241 ClientReader(::grpc::ChannelInterface* channel, in ClientReader() function
36 using grpc::ClientReader;98 std::unique_ptr<ClientReader<Feature> > reader( in ListFeatures()
60 std::unique_ptr<grpc::ClientReader<GaugeResponse>> reader( in PrintMetrics()
431 std::unique_ptr<ClientReader<StreamingOutputCallResponse>> stream( in DoResponseStreaming()546 std::unique_ptr<ClientReader<StreamingOutputCallResponse>> stream( in DoServerCompressedStreaming()596 std::unique_ptr<ClientReader<StreamingOutputCallResponse>> stream( in DoResponseStreamingWithSlowConsumer()
402 std::unique_ptr<ClientReader<Feature> > reader(414 context and request and get a `ClientReader` object back. The client can use the415 `ClientReader` to read the server's responses. We use the `ClientReader`s
95 …std::unique_ptr< ::grpc::ClientReader< flatbuffers::grpc::Message<Monster>>> Retrieve(::grpc::Clie… in Retrieve()96 …return std::unique_ptr< ::grpc::ClientReader< flatbuffers::grpc::Message<Monster>>>(RetrieveRaw(co… in Retrieve()127 …::grpc::ClientReader< flatbuffers::grpc::Message<Monster>>* RetrieveRaw(::grpc::ClientContext* con…
50 ::grpc::ClientReader< flatbuffers::grpc::Message<Monster>>* MonsterStorage::Stub::RetrieveRaw(::grp… in RetrieveRaw()
331 : public SynchronousStreamingClient<grpc::ClientReader<SimpleResponse>> {
158 …std::unique_ptr< ::grpc::ClientReader< ::grpc::testing::Response>> MethodA3(::grpc::ClientContext*…159 …return std::unique_ptr< ::grpc::ClientReader< ::grpc::testing::Response>>(MethodA3Raw(context, req…196 …::grpc::ClientReader< ::grpc::testing::Response>* MethodA3Raw(::grpc::ClientContext* context, cons…