Searched refs:ClientAsyncResponseReader (Results 1 – 16 of 16) sorted by relevance
83 static ClientAsyncResponseReader<R>* Create( in Create()89 call.call(), sizeof(ClientAsyncResponseReader<R>))) in Create()90 ClientAsyncResponseReader<R>(call, context, request, start); in Create()98 class ClientAsyncResponseReader final103 assert(size == sizeof(ClientAsyncResponseReader)); in delete()166 ClientAsyncResponseReader(::grpc::internal::Call call, ClientContext* context, in ClientAsyncResponseReader() function305 class default_delete<grpc::ClientAsyncResponseReader<R>> {
88 class ClientAsyncResponseReader; variable391 friend class ::grpc::ClientAsyncResponseReader;
29 using grpc::ClientAsyncResponseReader;67 std::unique_ptr<ClientAsyncResponseReader<HelloReply> > rpc( in SayHello()
30 using grpc::ClientAsyncResponseReader;109 std::unique_ptr<ClientAsyncResponseReader<HelloReply>> response_reader;
143 …std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::grpc::testing::Response>> AsyncMethodA1(::gr…144 …return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::grpc::testing::Response>>(AsyncMethod…146 …std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::grpc::testing::Response>> PrepareAsyncMethod…147 …return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::grpc::testing::Response>>(PrepareAsyn…191 …::grpc::ClientAsyncResponseReader< ::grpc::testing::Response>* AsyncMethodA1Raw(::grpc::ClientCont…192 …::grpc::ClientAsyncResponseReader< ::grpc::testing::Response>* PrepareAsyncMethodA1Raw(::grpc::Cli…537 …std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::grpc::testing::Response>> AsyncMethodB1(::gr…538 …return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::grpc::testing::Response>>(AsyncMethod…540 …std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::grpc::testing::Response>> PrepareAsyncMethod…541 …return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::grpc::testing::Response>>(PrepareAsyn…[all …]
89 …std::unique_ptr< ::grpc::ClientAsyncResponseReader< flatbuffers::grpc::Message<Stat>>> AsyncStore(… in AsyncStore()90 …return std::unique_ptr< ::grpc::ClientAsyncResponseReader< flatbuffers::grpc::Message<Stat>>>(Asyn… in AsyncStore()92 …std::unique_ptr< ::grpc::ClientAsyncResponseReader< flatbuffers::grpc::Message<Stat>>> PrepareAsyn… in PrepareAsyncStore()93 …return std::unique_ptr< ::grpc::ClientAsyncResponseReader< flatbuffers::grpc::Message<Stat>>>(Prep… in PrepareAsyncStore()125 …::grpc::ClientAsyncResponseReader< flatbuffers::grpc::Message<Stat>>* AsyncStoreRaw(::grpc::Client…126 …::grpc::ClientAsyncResponseReader< flatbuffers::grpc::Message<Stat>>* PrepareAsyncStoreRaw(::grpc:…
42 ::grpc::ClientAsyncResponseReader< flatbuffers::grpc::Message<Stat>>* MonsterStorage::Stub::AsyncSt… in AsyncStoreRaw()46 ::grpc::ClientAsyncResponseReader< flatbuffers::grpc::Message<Stat>>* MonsterStorage::Stub::Prepare… in PrepareAsyncStoreRaw()
34 typedef ClientAsyncResponseReader<ByteBuffer> GenericClientAsyncResponseReader;
316 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in SendRpc()426 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in TEST_P()467 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in TEST_P()886 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in TEST_P()928 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in TEST_P()973 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in TEST_P()1033 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in TEST_P()1092 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in TEST_P()1125 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in TEST_P()1161 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in TEST_P()
176 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in TEST_F()201 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in TEST_F()
127 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in SendRpc()
356 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader;
79 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in BM_UnaryPingPong()
393 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in BM_PumpUnbalancedUnary_Trickle()
70 std::unique_ptr<grpc::ClientAsyncResponseReader<ResponseType>>( in ClientRpcContextUnaryImpl()129 std::function<std::unique_ptr<grpc::ClientAsyncResponseReader<ResponseType>>(135 std::unique_ptr<grpc::ClientAsyncResponseReader<ResponseType>>321 static std::unique_ptr<grpc::ClientAsyncResponseReader<SimpleResponse>>
206 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in UnaryPingPong()