| /external/grpc-grpc/src/python/grpcio_tests/tests/protoc_plugin/ |
| D | _python_plugin_test.py | 90 def StreamingInputCall(self, request_iter, unused_rpc_context): member in _ServicerMethods
152 def StreamingInputCall(self, request_iter, context): member in _CreateService.Servicer
153 return servicer_methods.StreamingInputCall(request_iter, context)
352 response = service.stub.StreamingInputCall(
354 expected_response = service.servicer_methods.StreamingInputCall(
362 response_future = service.stub.StreamingInputCall.future(
365 expected_response = service.servicer_methods.StreamingInputCall(
373 response_future = service.stub.StreamingInputCall.future(
388 response_future = service.stub.StreamingInputCall.future(
399 response_future = service.stub.StreamingInputCall.future(
|
| D | beta_python_plugin_test.py | 158 def StreamingInputCall(self, request_iter, unused_rpc_context): member in _ServicerMethods
211 def StreamingInputCall(self, request_iter, context): member in _CreateService.Servicer
212 return servicer_methods.StreamingInputCall(request_iter, context)
482 response = stub.StreamingInputCall(
486 expected_response = methods.StreamingInputCall(
498 response_future = stub.StreamingInputCall.future(
503 expected_response = methods.StreamingInputCall(
515 response_future = stub.StreamingInputCall.future(
530 response_future = stub.StreamingInputCall.future(
545 response_future = stub.StreamingInputCall.future(
|
| /external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/ |
| D | SslCredentialsTest.cs | 89 var call = client.StreamingInputCall(); in AuthContextIsPopulated()
102 …public override async Task<StreamingInputCallResponse> StreamingInputCall(IAsyncStreamReader<Strea… in StreamingInputCall() method in Grpc.IntegrationTesting.SslCredentialsTest.SslCredentialsTestServiceImpl
|
| D | GeneratedClientTest.cs | 45 … Assert.Throws(typeof(NotImplementedException), () => unimplementedClient.StreamingInputCall()); in DefaultMethodStubThrows_ClientStreaming()
|
| D | InteropClient.cs | 230 using (var call = client.StreamingInputCall()) in RunClientStreamingAsync()
405 using (var call = client.StreamingInputCall(cancellationToken: cts.Token)) in RunCancelAfterBeginAsync()
635 var probeCall = client.StreamingInputCall(CreateClientCompressionMetadata(false)); in RunClientCompressedStreamingAsync()
654 var call = client.StreamingInputCall(CreateClientCompressionMetadata(true)); in RunClientCompressedStreamingAsync()
|
| D | GeneratedServiceBaseTest.cs | 70 var call = client.StreamingInputCall(); in UnimplementedByDefault_ClientStreaming()
|
| D | TestGrpc.cs | 165 …eading.Tasks.Task<global::Grpc.Testing.StreamingInputCallResponse> StreamingInputCall(grpc::IAsync… in StreamingInputCall() method in Grpc.Testing.TestService.TestServiceBase
408 …InputCallRequest, global::Grpc.Testing.StreamingInputCallResponse> StreamingInputCall(grpc::Metada… in StreamingInputCall() method in Grpc.Testing.TestService.TestServiceClient
410 return StreamingInputCall(new grpc::CallOptions(headers, deadline, cancellationToken)); in StreamingInputCall()
418 …InputCallRequest, global::Grpc.Testing.StreamingInputCallResponse> StreamingInputCall(grpc::CallOp… in StreamingInputCall() method in Grpc.Testing.TestService.TestServiceClient
536 .AddMethod(__Method_StreamingInputCall, serviceImpl.StreamingInputCall) in BindService()
|
| D | TestServiceImpl.cs | 61 …public override async Task<StreamingInputCallResponse> StreamingInputCall(IAsyncStreamReader<Strea… in StreamingInputCall() method in Grpc.Testing.TestServiceImpl
|
| /external/grpc-grpc/src/php/tests/qps/generated_code/Grpc/Testing/ |
| D | TestServiceClient.php | 104 public function StreamingInputCall($metadata = [], $options = []) { function in Grpc\\Testing\\TestServiceClient
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/interop/ |
| D | methods.py | 78 def StreamingInputCall(self, request_iterator, context): member in TestService
166 response = stub.StreamingInputCall(requests)
264 response_future = stub.StreamingInputCall.future(pipe)
|
| /external/grpc-grpc/doc/ |
| D | interop-test-descriptions.md | 236 * [StreamingInputCall][]
239 1. Client calls StreamingInputCall
295 1. Client calls `StreamingInputCall` and sends the following feature-probing
311 1. Client calls `StreamingInputCall` again, sending the *compressed* message
854 * [StreamingInputCall][]
857 1. Client starts StreamingInputCall
1071 ### StreamingInputCall subsection
1072 [StreamingInputCall]: #streaminginputcall argument
1074 Server implements StreamingInputCall which upon half close immediately returns
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/protoc_plugin/protos/service/ |
| D | test_service.proto | 34 rpc StreamingInputCall(stream StreamingInputCallRequest) rpc
|
| /external/grpc-grpc/src/objective-c/tests/RemoteTestClient/ |
| D | test.proto | 42 rpc StreamingInputCall(stream StreamingInputCallRequest) rpc
|
| /external/grpc-grpc/src/objective-c/examples/RemoteTestClient/ |
| D | test.proto | 42 rpc StreamingInputCall(stream StreamingInputCallRequest) rpc
|
| /external/grpc-grpc/test/cpp/interop/ |
| D | interop_client.cc | 398 serviceStub_.Get()->StreamingInputCall(&context, &response)); in DoRequestStreaming()
473 serviceStub_.Get()->StreamingInputCall(&probe_context, &probe_res)); in DoClientCompressedStreaming()
495 serviceStub_.Get()->StreamingInputCall(&context, &response)); in DoClientCompressedStreaming()
727 serviceStub_.Get()->StreamingInputCall(&context, &response)); in DoCancelAfterBegin()
|
| D | interop_server.cc | 234 Status StreamingInputCall(ServerContext* context, in StreamingInputCall() function in TestServiceImpl
|
| /external/grpc-grpc-java/compiler/src/test/proto/grpc/testing/compiler/ |
| D | test.proto | 54 rpc StreamingInputCall(stream StreamingInputCallRequest) rpc
|
| /external/grpc-grpc/src/php/tests/interop/ |
| D | interop_client.php | 249 $call = $stub->StreamingInputCall();
348 $call = $stub->StreamingInputCall();
|
| /external/grpc-grpc/src/proto/grpc/testing/ |
| D | test.proto | 47 rpc StreamingInputCall(stream StreamingInputCallRequest) rpc
|
| /external/grpc-grpc-java/interop-testing/src/main/proto/grpc/testing/ |
| D | test.proto | 46 rpc StreamingInputCall(stream StreamingInputCallRequest) rpc
|
| /external/rust/crates/grpcio-sys/grpc/src/proto/grpc/testing/ |
| D | test.proto | 47 rpc StreamingInputCall(stream StreamingInputCallRequest) rpc
|
| /external/grpc-grpc-java/compiler/src/test/golden/ |
| D | TestService.java.txt | 101 fullMethodName = SERVICE_NAME + '/' + "StreamingInputCall",
115 "grpc.testing.compiler.TestService", "StreamingInputCall"))
121 … .setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("StreamingInputCall"))
|
| /external/grpc-grpc-java/compiler/src/testLite/golden/ |
| D | TestService.java.txt | 99 fullMethodName = SERVICE_NAME + '/' + "StreamingInputCall",
113 "grpc.testing.compiler.TestService", "StreamingInputCall"))
|
| /external/grpc-grpc-java/compiler/src/testNano/golden/ |
| D | TestService.java.txt | 106 "grpc.testing.compiler.TestService", "StreamingInputCall"))
|