Home
last modified time | relevance | path

Searched refs:ClientReaderWriter (Results 1 – 18 of 18) sorted by relevance

/third_party/grpc/include/grpcpp/impl/codegen/
Dchannel_interface.h33 class ClientReaderWriter; variable
111 friend class ::grpc::ClientReaderWriter;
Dcompletion_queue_impl.h56 class ClientReaderWriter; variable
268 friend class ::grpc_impl::ClientReaderWriter;
Dsync_stream_impl.h434 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
Dsync_stream.h433 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
Dclient_context.h83 class ClientReaderWriter; variable
434 friend class ::grpc::ClientReaderWriter;
Dclient_context_impl.h100 class ClientReaderWriter; variable
427 friend class ::grpc_impl::ClientReaderWriter;
Dcompletion_queue.h54 class ClientReaderWriter; variable
267 friend class ::grpc::ClientReaderWriter;
/third_party/grpc/test/cpp/interop/
Dinterop_client.cc653 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/
Droute_guide_client.cc41 using grpc::ClientReaderWriter;
161 std::shared_ptr<ClientReaderWriter<RouteNote, RouteNote> > stream( in RouteChat()
/third_party/grpc/test/cpp/util/
Dproto_reflection_descriptor_database.h80 typedef ClientReaderWriter<
/third_party/grpc/test/cpp/end2end/
Dstreaming_throughput_test.cc159 static void Drainer(ClientReaderWriter<EchoRequest, EchoResponse>* reader) { in Drainer()
Dend2end_test.cc1308 void ReaderThreadFunc(ClientReaderWriter<EchoRequest, EchoResponse>* stream, in ReaderThreadFunc()
/third_party/grpc/examples/cpp/keyvaluestore/
Dcaching_interceptor.h121 grpc::ClientReaderWriter<keyvaluestore::Request, keyvaluestore::Response>>
/third_party/grpc/test/cpp/qps/
Dclient_sync.cc220 grpc::ClientReaderWriter<SimpleRequest, SimpleResponse>> {
376 grpc::ClientReaderWriter<SimpleRequest, SimpleResponse>> {
Ddriver.cc232 unique_ptr<ClientReaderWriter<ClientArgs, ClientStatus>> stream;
237 unique_ptr<ClientReaderWriter<ServerArgs, ServerStatus>> stream;
/third_party/flatbuffers/tests/
Dmonster_test.grpc.fb.h113 …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>>…
Dmonster_test.grpc.fb.cc74 ::grpc::ClientReaderWriter< flatbuffers::grpc::Message<Monster>, flatbuffers::grpc::Message<Stat>>*… in GetMinMaxHitPointsRaw()
/third_party/grpc/test/cpp/codegen/
Dcompiler_test_golden200 …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…