Searched refs:ClientAsyncReader (Results 1 – 8 of 8) sorted by relevance
183 static ClientAsyncReader<R>* Create(ChannelInterface* channel, in Create()190 call.call(), sizeof(ClientAsyncReader<R>))) in Create()191 ClientAsyncReader<R>(call, context, request, start, tag); in Create()200 class ClientAsyncReader final : public ClientAsyncReaderInterface<R> {204 assert(size == sizeof(ClientAsyncReader)); in delete()265 ClientAsyncReader(::grpc::internal::Call call, ClientContext* context, in ClientAsyncReader() function
82 class ClientAsyncReader; variable385 friend class ::grpc::ClientAsyncReader;
98 …std::unique_ptr< ::grpc::ClientAsyncReader< flatbuffers::grpc::Message<Monster>>> AsyncRetrieve(::… in AsyncRetrieve()99 …return std::unique_ptr< ::grpc::ClientAsyncReader< flatbuffers::grpc::Message<Monster>>>(AsyncRetr… in AsyncRetrieve()101 …std::unique_ptr< ::grpc::ClientAsyncReader< flatbuffers::grpc::Message<Monster>>> PrepareAsyncRetr… in PrepareAsyncRetrieve()102 …return std::unique_ptr< ::grpc::ClientAsyncReader< flatbuffers::grpc::Message<Monster>>>(PrepareAs… in PrepareAsyncRetrieve()128 …::grpc::ClientAsyncReader< flatbuffers::grpc::Message<Monster>>* AsyncRetrieveRaw(::grpc::ClientCo…129 …::grpc::ClientAsyncReader< flatbuffers::grpc::Message<Monster>>* PrepareAsyncRetrieveRaw(::grpc::C…
54 ::grpc::ClientAsyncReader< flatbuffers::grpc::Message<Monster>>* MonsterStorage::Stub::AsyncRetriev… in AsyncRetrieveRaw()58 ::grpc::ClientAsyncReader< flatbuffers::grpc::Message<Monster>>* MonsterStorage::Stub::PrepareAsync… in PrepareAsyncRetrieveRaw()
657 std::function<std::unique_ptr<grpc::ClientAsyncReader<ResponseType>>( in ClientRpcContextStreamingFromServerImpl()719 std::function<std::unique_ptr<grpc::ClientAsyncReader<ResponseType>>(725 std::unique_ptr<grpc::ClientAsyncReader<ResponseType>> stream_;749 static std::unique_ptr<grpc::ClientAsyncReader<SimpleResponse>> PrepareReq( in PrepareReq()
161 …std::unique_ptr< ::grpc::ClientAsyncReader< ::grpc::testing::Response>> AsyncMethodA3(::grpc::Clie…162 …return std::unique_ptr< ::grpc::ClientAsyncReader< ::grpc::testing::Response>>(AsyncMethodA3Raw(co…164 …std::unique_ptr< ::grpc::ClientAsyncReader< ::grpc::testing::Response>> PrepareAsyncMethodA3(::grp…165 …return std::unique_ptr< ::grpc::ClientAsyncReader< ::grpc::testing::Response>>(PrepareAsyncMethodA…197 …::grpc::ClientAsyncReader< ::grpc::testing::Response>* AsyncMethodA3Raw(::grpc::ClientContext* con…198 …::grpc::ClientAsyncReader< ::grpc::testing::Response>* PrepareAsyncMethodA3Raw(::grpc::ClientConte…
608 std::unique_ptr<ClientAsyncReader<EchoResponse>> cli_stream( in TEST_P()652 std::unique_ptr<ClientAsyncReader<EchoResponse>> cli_stream( in TEST_P()695 std::unique_ptr<ClientAsyncReader<EchoResponse>> cli_stream( in TEST_P()1366 std::unique_ptr<ClientAsyncReader<EchoResponse>> cli_stream( in TestServerStreamingServerCancel()
275 std::unique_ptr<ClientAsyncReader<EchoResponse>> cli_stream( in TEST_F()