HomeSort by relevance Sort by last modified time
    Searched refs:StreamingCall (Results 1 - 13 of 13) sorted by null

  /external/grpc-grpc/src/python/grpcio_tests/tests/qps/
benchmark_server.py 26 def StreamingCall(self, request_iterator, context):
42 def StreamingCall(self, request_iterator, context):
benchmark_client.py 37 self.StreamingCall = channel.stream_stream(
38 '/grpc.testing.BenchmarkService/StreamingCall')
155 response_stream = self._stub.StreamingCall(self._request_generator(),
worker_server.py 82 'StreamingCall':
83 grpc.stream_stream_rpc_method_handler(servicer.StreamingCall),
  /external/grpc-grpc/src/ruby/qps/src/proto/grpc/testing/
benchmark_service_services_pb.rb 41 rpc :StreamingCall, stream(SimpleRequest), stream(SimpleResponse)
  /external/grpc-grpc/src/php/tests/qps/generated_code/Grpc/Testing/
BenchmarkServiceClient.php 58 public function StreamingCall($metadata = [], $options = []) {
59 return $this->_bidiRequest('/grpc.testing.BenchmarkService/StreamingCall',
  /external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/
BenchmarkServiceImpl.cs 44 public override async Task StreamingCall(IAsyncStreamReader<SimpleRequest> requestStream, IServerStreamWriter<SimpleResponse> responseStream, ServerCallContext context)
GenericService.cs 45 "StreamingCall",
ServerRunners.cs 74 service = GenericService.BindHandler(genericService.StreamingCall);
104 public async Task StreamingCall(IAsyncStreamReader<byte[]> requestStream, IServerStreamWriter<byte[]> responseStream, ServerCallContext context)
BenchmarkServiceGrpc.cs 45 "StreamingCall",
100 public virtual global::System.Threading.Tasks.Task StreamingCall(grpc::IAsyncStreamReader<global::Grpc.Testing.SimpleRequest> requestStream, grpc::IServerStreamWriter<global::Grpc.Testing.SimpleResponse> responseStream, grpc::ServerCallContext context)
225 public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.SimpleRequest, global::Grpc.Testing.SimpleResponse> StreamingCall(grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken))
227 return StreamingCall(new grpc::CallOptions(headers, deadline, cancellationToken));
236 public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.SimpleRequest, global::Grpc.Testing.SimpleResponse> StreamingCall(grpc::CallOptions options)
321 .AddMethod(__Method_StreamingCall, serviceImpl.StreamingCall)
ClientRunners.cs 258 using (var call = client.StreamingCall())
  /external/grpc-grpc/src/php/tests/qps/
client.php 149 $stream = $stub->StreamingCall();
  /external/grpc-grpc/test/cpp/qps/
client_sync.cc 235 stream_[thread_idx] = stub->StreamingCall(&context_[thread_idx]);
267 stream_[thread_idx] = stub->StreamingCall(&context_[thread_idx]);
server_sync.cc 47 Status StreamingCall(

Completed in 665 milliseconds