Lines Matching refs:Stub
67 BenchmarkService::Stub* stub, const RequestType& req,
71 BenchmarkService::Stub*, grpc::ClientContext*, const RequestType&,
76 stub_(stub),
120 BenchmarkService::Stub* stub_;
130 BenchmarkService::Stub*, grpc::ClientContext*, const RequestType&,
301 static std::unique_ptr<BenchmarkService::Stub> BenchmarkStubCreator(
307 : public AsyncClient<BenchmarkService::Stub, SimpleRequest> {
310 : AsyncClient<BenchmarkService::Stub, SimpleRequest>(
322 PrepareReq(BenchmarkService::Stub* stub, grpc::ClientContext* ctx,
324 return stub->PrepareAsyncUnaryCall(ctx, request, cq);
326 static ClientRpcContext* SetupCtx(BenchmarkService::Stub* stub,
330 stub, req, std::move(next_issue), AsyncUnaryClient::PrepareReq,
339 BenchmarkService::Stub* stub, const RequestType& req,
343 BenchmarkService::Stub*, grpc::ClientContext*, CompletionQueue*)>
347 stub_(stub),
435 BenchmarkService::Stub* stub_;
455 BenchmarkService::Stub*, grpc::ClientContext*, CompletionQueue*)>
490 : public AsyncClient<BenchmarkService::Stub, SimpleRequest> {
493 : AsyncClient<BenchmarkService::Stub, SimpleRequest>(
504 PrepareReq(BenchmarkService::Stub* stub, grpc::ClientContext* ctx,
506 auto stream = stub->PrepareAsyncStreamingCall(ctx, cq);
509 static ClientRpcContext* SetupCtx(BenchmarkService::Stub* stub,
514 stub, req, std::move(next_issue),
524 BenchmarkService::Stub* stub, const RequestType& req,
527 BenchmarkService::Stub*, grpc::ClientContext*, ResponseType*,
532 stub_(stub),
590 BenchmarkService::Stub* stub_;
606 BenchmarkService::Stub*, grpc::ClientContext*, ResponseType*,
622 : public AsyncClient<BenchmarkService::Stub, SimpleRequest> {
625 : AsyncClient<BenchmarkService::Stub, SimpleRequest>(
635 BenchmarkService::Stub* stub, grpc::ClientContext* ctx,
637 auto stream = stub->PrepareAsyncStreamingFromClient(ctx, resp, cq);
640 static ClientRpcContext* SetupCtx(BenchmarkService::Stub* stub,
645 stub, req, std::move(next_issue),
655 BenchmarkService::Stub* stub, const RequestType& req,
658 BenchmarkService::Stub*, grpc::ClientContext*, const RequestType&,
663 stub_(stub),
710 BenchmarkService::Stub* stub_;
720 BenchmarkService::Stub*, grpc::ClientContext*, const RequestType&,
737 : public AsyncClient<BenchmarkService::Stub, SimpleRequest> {
740 : AsyncClient<BenchmarkService::Stub, SimpleRequest>(
750 BenchmarkService::Stub* stub, grpc::ClientContext* ctx,
752 auto stream = stub->PrepareAsyncStreamingFromServer(ctx, req, cq);
755 static ClientRpcContext* SetupCtx(BenchmarkService::Stub* stub,
760 stub, req, std::move(next_issue),
769 grpc::GenericStub* stub, const ByteBuffer& req,
777 stub_(stub),
916 grpc::GenericStub* stub, grpc::ClientContext* ctx,
918 auto stream = stub->PrepareCall(ctx, method_name, cq);
921 static ClientRpcContext* SetupCtx(grpc::GenericStub* stub,
925 stub, req, std::move(next_issue),
