| /external/grpc-grpc/src/python/grpcio_tests/tests/qps/ |
| D | benchmark_server.py | 26 def StreamingCall(self, request_iterator, context): member in BenchmarkServer
42 def StreamingCall(self, request_iterator, context): member in GenericBenchmarkServer
|
| D | benchmark_client.py | 37 self.StreamingCall = channel.stream_stream(
155 response_stream = self._stub.StreamingCall(self._request_generator(),
|
| D | worker_server.py | 83 grpc.stream_stream_rpc_method_handler(servicer.StreamingCall),
|
| /external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/ |
| D | BenchmarkServiceGrpc.cs | 100 …public virtual global::System.Threading.Tasks.Task StreamingCall(grpc::IAsyncStreamReader<global::… in StreamingCall() method in Grpc.Testing.BenchmarkService.BenchmarkServiceBase
225 …bal::Grpc.Testing.SimpleRequest, global::Grpc.Testing.SimpleResponse> StreamingCall(grpc::Metadata… in StreamingCall() method in Grpc.Testing.BenchmarkService.BenchmarkServiceClient
227 return StreamingCall(new grpc::CallOptions(headers, deadline, cancellationToken)); in StreamingCall()
236 …bal::Grpc.Testing.SimpleRequest, global::Grpc.Testing.SimpleResponse> StreamingCall(grpc::CallOpti… in StreamingCall() method in Grpc.Testing.BenchmarkService.BenchmarkServiceClient
321 .AddMethod(__Method_StreamingCall, serviceImpl.StreamingCall) in BindService()
|
| D | ServerRunners.cs | 74 service = GenericService.BindHandler(genericService.StreamingCall); in CreateStarted()
104 …public async Task StreamingCall(IAsyncStreamReader<byte[]> requestStream, IServerStreamWriter<byte… in StreamingCall() method in Grpc.IntegrationTesting.ServerRunners.GenericServiceImpl
|
| D | BenchmarkServiceImpl.cs | 44 …public override async Task StreamingCall(IAsyncStreamReader<SimpleRequest> requestStream, IServerS… in StreamingCall() method in Grpc.Testing.BenchmarkServiceImpl
|
| D | ClientRunners.cs | 258 using (var call = client.StreamingCall()) in RunStreamingPingPongAsync()
|
| /external/llvm-project/clang-tools-extra/clangd/index/remote/ |
| D | Client.cpp | 30 using StreamingCall = std::unique_ptr<grpc::ClientReader<ReplyT>> ( typedef in clang::clangd::remote::__anon64f54a130111::IndexClient
37 StreamingCall<RequestT, ReplyT> RPCCall, in streamRPC()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/ |
| D | grpc_eager_service_impl.h | 38 using StreamingCall = variable
121 StreamingCall<EnqueueRequest, EnqueueResponse>* call) { in StreamingEnqueueHandler()
|
| /external/grpc-grpc/src/php/tests/qps/generated_code/Grpc/Testing/ |
| D | BenchmarkServiceClient.php | 58 public function StreamingCall($metadata = [], $options = []) { function in Grpc\\Testing\\BenchmarkServiceClient
|
| /external/grpc-grpc/test/cpp/qps/ |
| D | client_sync.cc | 235 stream_[thread_idx] = stub->StreamingCall(&context_[thread_idx]); in InitThreadFuncImpl()
267 stream_[thread_idx] = stub->StreamingCall(&context_[thread_idx]); in ThreadFuncImpl()
|
| D | server_sync.cc | 47 Status StreamingCall( in StreamingCall() function in grpc::testing::BenchmarkServiceImpl
|
| /external/grpc-grpc/src/proto/grpc/testing/ |
| D | benchmark_service.proto | 31 rpc StreamingCall(stream SimpleRequest) returns (stream SimpleResponse); rpc
|
| /external/rust/crates/grpcio-sys/grpc/src/proto/grpc/testing/ |
| D | benchmark_service.proto | 31 rpc StreamingCall(stream SimpleRequest) returns (stream SimpleResponse); rpc
|
| /external/grpc-grpc/src/php/tests/qps/ |
| D | client.php | 149 $stream = $stub->StreamingCall();
|
| /external/grpc-grpc-java/benchmarks/src/main/proto/grpc/testing/ |
| D | services.proto | 34 rpc StreamingCall(stream SimpleRequest) returns (stream SimpleResponse); rpc
|