Home
last modified time | relevance | path

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

/external/grpc-grpc/include/grpcpp/impl/codegen/
Dchannel_interface.h36 class ClientReaderWriter; variable
97 friend class ::grpc::ClientReaderWriter;
Dclient_context.h80 class ClientReaderWriter; variable
383 friend class ::grpc::ClientReaderWriter;
Dcompletion_queue.h51 class ClientReaderWriter; variable
254 friend class ::grpc::ClientReaderWriter;
Dsync_stream.h432 static ClientReaderWriter<W, R>* Create( in Create()
435 return new ClientReaderWriter<W, R>(channel, method, context); in Create()
445 class ClientReaderWriter final : public ClientReaderWriterInterface<W, R> {
549 ClientReaderWriter(::grpc::ChannelInterface* channel, in ClientReaderWriter() function
/external/grpc-grpc/test/cpp/interop/
Dinterop_client.cc632 std::unique_ptr<ClientReaderWriter<StreamingOutputCallRequest, in DoHalfDuplex()
679 std::unique_ptr<ClientReaderWriter<StreamingOutputCallRequest, in DoPingPong()
746 std::unique_ptr<ClientReaderWriter<StreamingOutputCallRequest, in DoCancelAfterFirstResponse()
783 std::unique_ptr<ClientReaderWriter<StreamingOutputCallRequest, in DoTimeoutOnSleepingServer()
805 std::unique_ptr<ClientReaderWriter<StreamingOutputCallRequest, in DoEmptyStream()
844 std::shared_ptr<ClientReaderWriter<StreamingOutputCallRequest, in DoStatusWithMessage()
974 std::unique_ptr<ClientReaderWriter<StreamingOutputCallRequest, in DoCustomMetadata()
/external/grpc-grpc/examples/cpp/route_guide/
Droute_guide_client.cc37 using grpc::ClientReaderWriter;
157 std::shared_ptr<ClientReaderWriter<RouteNote, RouteNote> > stream( in RouteChat()
/external/grpc-grpc/test/cpp/util/
Dproto_reflection_descriptor_database.h80 typedef ClientReaderWriter<
/external/grpc-grpc/test/cpp/qps/
Dclient_sync.cc221 grpc::ClientReaderWriter<SimpleRequest, SimpleResponse>> {
377 grpc::ClientReaderWriter<SimpleRequest, SimpleResponse>> {
Ddriver.cc269 unique_ptr<ClientReaderWriter<ServerArgs, ServerStatus>> stream; in RunScenario()
329 unique_ptr<ClientReaderWriter<ClientArgs, ClientStatus>> stream; in RunScenario()
/external/grpc-grpc/test/cpp/end2end/
Dstreaming_throughput_test.cc159 static void Drainer(ClientReaderWriter<EchoRequest, EchoResponse>* reader) { in Drainer()
Dend2end_test.cc1091 void ReaderThreadFunc(ClientReaderWriter<EchoRequest, EchoResponse>* stream, in ReaderThreadFunc()
/external/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()
/external/grpc-grpc/test/cpp/codegen/
Dcompiler_test_golden167 …std::unique_ptr< ::grpc::ClientReaderWriter< ::grpc::testing::Request, ::grpc::testing::Response>>…
168 …return std::unique_ptr< ::grpc::ClientReaderWriter< ::grpc::testing::Request, ::grpc::testing::Res…
199 …::grpc::ClientReaderWriter< ::grpc::testing::Request, ::grpc::testing::Response>* MethodA4Raw(::gr…
/external/grpc-grpc/examples/cpp/
Dcpptutorial.md461 case, we just pass a context to the method and get back a `ClientReaderWriter`,
465 std::shared_ptr<ClientReaderWriter<RouteNote, RouteNote> > stream(