/third_party/grpc/include/grpcpp/impl/codegen/ |
D | channel_interface.h | 33 class ClientReaderWriter; variable 111 friend class ::grpc::ClientReaderWriter;
|
D | completion_queue_impl.h | 56 class ClientReaderWriter; variable 268 friend class ::grpc_impl::ClientReaderWriter;
|
D | sync_stream_impl.h | 434 static ClientReaderWriter<W, R>* Create( in Create() 438 return new ClientReaderWriter<W, R>(channel, method, context); in Create() 448 class ClientReaderWriter final : public ClientReaderWriterInterface<W, R> { 553 ClientReaderWriter(::grpc::ChannelInterface* channel, in ClientReaderWriter() function
|
D | sync_stream.h | 433 static ClientReaderWriter<W, R>* Create( in Create() 437 return new ClientReaderWriter<W, R>(channel, method, context); in Create() 447 class ClientReaderWriter final : public ClientReaderWriterInterface<W, R> { 552 ClientReaderWriter(::grpc::ChannelInterface* channel, in ClientReaderWriter() function
|
D | client_context.h | 83 class ClientReaderWriter; variable 434 friend class ::grpc::ClientReaderWriter;
|
D | client_context_impl.h | 100 class ClientReaderWriter; variable 427 friend class ::grpc_impl::ClientReaderWriter;
|
D | completion_queue.h | 54 class ClientReaderWriter; variable 267 friend class ::grpc::ClientReaderWriter;
|
/third_party/grpc/test/cpp/interop/ |
D | interop_client.cc | 653 std::unique_ptr<ClientReaderWriter<StreamingOutputCallRequest, in DoHalfDuplex() 700 std::unique_ptr<ClientReaderWriter<StreamingOutputCallRequest, in DoPingPong() 767 std::unique_ptr<ClientReaderWriter<StreamingOutputCallRequest, in DoCancelAfterFirstResponse() 804 std::unique_ptr<ClientReaderWriter<StreamingOutputCallRequest, in DoTimeoutOnSleepingServer() 826 std::unique_ptr<ClientReaderWriter<StreamingOutputCallRequest, in DoEmptyStream() 865 std::shared_ptr<ClientReaderWriter<StreamingOutputCallRequest, in DoStatusWithMessage() 1021 std::unique_ptr<ClientReaderWriter<StreamingOutputCallRequest, in DoCustomMetadata()
|
/third_party/grpc/examples/cpp/route_guide/ |
D | route_guide_client.cc | 41 using grpc::ClientReaderWriter; 161 std::shared_ptr<ClientReaderWriter<RouteNote, RouteNote> > stream( in RouteChat()
|
/third_party/grpc/test/cpp/util/ |
D | proto_reflection_descriptor_database.h | 80 typedef ClientReaderWriter<
|
/third_party/grpc/test/cpp/end2end/ |
D | streaming_throughput_test.cc | 159 static void Drainer(ClientReaderWriter<EchoRequest, EchoResponse>* reader) { in Drainer()
|
D | end2end_test.cc | 1308 void ReaderThreadFunc(ClientReaderWriter<EchoRequest, EchoResponse>* stream, in ReaderThreadFunc()
|
/third_party/grpc/examples/cpp/keyvaluestore/ |
D | caching_interceptor.h | 121 grpc::ClientReaderWriter<keyvaluestore::Request, keyvaluestore::Response>>
|
/third_party/grpc/test/cpp/qps/ |
D | client_sync.cc | 220 grpc::ClientReaderWriter<SimpleRequest, SimpleResponse>> { 376 grpc::ClientReaderWriter<SimpleRequest, SimpleResponse>> {
|
D | driver.cc | 232 unique_ptr<ClientReaderWriter<ClientArgs, ClientStatus>> stream; 237 unique_ptr<ClientReaderWriter<ServerArgs, ServerStatus>> stream;
|
/third_party/flatbuffers/tests/ |
D | monster_test.grpc.fb.h | 113 …std::unique_ptr< ::grpc::ClientReaderWriter< flatbuffers::grpc::Message<Monster>, flatbuffers::grp… in GetMinMaxHitPoints() 114 …return std::unique_ptr< ::grpc::ClientReaderWriter< flatbuffers::grpc::Message<Monster>, flatbuffe… in GetMinMaxHitPoints() 133 …::grpc::ClientReaderWriter< flatbuffers::grpc::Message<Monster>, flatbuffers::grpc::Message<Stat>>…
|
D | monster_test.grpc.fb.cc | 74 ::grpc::ClientReaderWriter< flatbuffers::grpc::Message<Monster>, flatbuffers::grpc::Message<Stat>>*… in GetMinMaxHitPointsRaw()
|
/third_party/grpc/test/cpp/codegen/ |
D | compiler_test_golden | 200 …std::unique_ptr< ::grpc::ClientReaderWriter< ::grpc::testing::Request, ::grpc::testing::Response>>… 201 …return std::unique_ptr< ::grpc::ClientReaderWriter< ::grpc::testing::Request, ::grpc::testing::Res… 258 …::grpc::ClientReaderWriter< ::grpc::testing::Request, ::grpc::testing::Response>* MethodA4Raw(::gr…
|