Searched refs:ClientAsyncWriter (Results 1 – 8 of 8) sorted by relevance
331 static ClientAsyncWriter<W>* Create(ChannelInterface* channel, in Create()338 call.call(), sizeof(ClientAsyncWriter<W>))) in Create()339 ClientAsyncWriter<W>(call, context, response, start, tag); in Create()348 class ClientAsyncWriter final : public ClientAsyncWriterInterface<W> {352 assert(size == sizeof(ClientAsyncWriter)); in delete()431 ClientAsyncWriter(::grpc::internal::Call call, ClientContext* context, in ClientAsyncWriter() function
84 class ClientAsyncWriter; variable387 friend class ::grpc::ClientAsyncWriter;
107 …std::unique_ptr< ::grpc::ClientAsyncWriter< flatbuffers::grpc::Message<Monster>>> AsyncGetMaxHitPo… in AsyncGetMaxHitPoint()108 …return std::unique_ptr< ::grpc::ClientAsyncWriter< flatbuffers::grpc::Message<Monster>>>(AsyncGetM… in AsyncGetMaxHitPoint()110 …std::unique_ptr< ::grpc::ClientAsyncWriter< flatbuffers::grpc::Message<Monster>>> PrepareAsyncGetM… in PrepareAsyncGetMaxHitPoint()111 …return std::unique_ptr< ::grpc::ClientAsyncWriter< flatbuffers::grpc::Message<Monster>>>(PrepareAs… in PrepareAsyncGetMaxHitPoint()131 …::grpc::ClientAsyncWriter< flatbuffers::grpc::Message<Monster>>* AsyncGetMaxHitPointRaw(::grpc::Cl…132 …::grpc::ClientAsyncWriter< flatbuffers::grpc::Message<Monster>>* PrepareAsyncGetMaxHitPointRaw(::g…
66 ::grpc::ClientAsyncWriter< flatbuffers::grpc::Message<Monster>>* MonsterStorage::Stub::AsyncGetMaxH… in AsyncGetMaxHitPointRaw()70 ::grpc::ClientAsyncWriter< flatbuffers::grpc::Message<Monster>>* MonsterStorage::Stub::PrepareAsync… in PrepareAsyncGetMaxHitPointRaw()
526 std::function<std::unique_ptr<grpc::ClientAsyncWriter<RequestType>>( in ClientRpcContextStreamingFromClientImpl()605 std::function<std::unique_ptr<grpc::ClientAsyncWriter<RequestType>>(611 std::unique_ptr<grpc::ClientAsyncWriter<RequestType>> stream_;634 static std::unique_ptr<grpc::ClientAsyncWriter<SimpleRequest>> PrepareReq( in PrepareReq()
152 …std::unique_ptr< ::grpc::ClientAsyncWriter< ::grpc::testing::Request>> AsyncMethodA2(::grpc::Clien…153 …return std::unique_ptr< ::grpc::ClientAsyncWriter< ::grpc::testing::Request>>(AsyncMethodA2Raw(con…155 …std::unique_ptr< ::grpc::ClientAsyncWriter< ::grpc::testing::Request>> PrepareAsyncMethodA2(::grpc…156 …return std::unique_ptr< ::grpc::ClientAsyncWriter< ::grpc::testing::Request>>(PrepareAsyncMethodA2…194 …::grpc::ClientAsyncWriter< ::grpc::testing::Request>* AsyncMethodA2Raw(::grpc::ClientContext* cont…195 …::grpc::ClientAsyncWriter< ::grpc::testing::Request>* PrepareAsyncMethodA2Raw(::grpc::ClientContex…
230 std::unique_ptr<ClientAsyncWriter<EchoRequest>> cli_stream( in TEST_F()
512 std::unique_ptr<ClientAsyncWriter<EchoRequest>> cli_stream( in TEST_P()559 std::unique_ptr<ClientAsyncWriter<EchoRequest>> cli_stream( in TEST_P()1211 std::unique_ptr<ClientAsyncWriter<EchoRequest>> cli_stream( in TestClientStreamingServerCancel()