Home
last modified time | relevance | path

Searched refs:StreamingOutputCallRequest (Results 1 – 25 of 48) sorted by relevance

12

/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/
DAbstractInteropTest.java95 import io.grpc.testing.integration.Messages.StreamingOutputCallRequest;
502 final StreamingOutputCallRequest request = StreamingOutputCallRequest.newBuilder() in serverStreaming()
638 final StreamingOutputCallRequest request = in serverCompressedStreaming()
639 StreamingOutputCallRequest.newBuilder() in serverCompressedStreaming()
667 final List<StreamingOutputCallRequest> requests = Arrays.asList( in pingPong()
668 StreamingOutputCallRequest.newBuilder() in pingPong()
674 StreamingOutputCallRequest.newBuilder() in pingPong()
680 StreamingOutputCallRequest.newBuilder() in pingPong()
686 StreamingOutputCallRequest.newBuilder() in pingPong()
715 StreamObserver<StreamingOutputCallRequest> requestObserver in pingPong()
[all …]
DTestServiceImpl.java38 import io.grpc.testing.integration.Messages.StreamingOutputCallRequest;
135 public void streamingOutputCall(StreamingOutputCallRequest request, in streamingOutputCall()
175 public StreamObserver<Messages.StreamingOutputCallRequest> fullDuplexCall( in fullDuplexCall()
178 return new StreamObserver<StreamingOutputCallRequest>() { in fullDuplexCall()
180 public void onNext(StreamingOutputCallRequest request) { in fullDuplexCall()
211 public StreamObserver<Messages.StreamingOutputCallRequest> halfDuplexCall(
215 return new StreamObserver<StreamingOutputCallRequest>() {
217 public void onNext(StreamingOutputCallRequest request) {
384 public Queue<Chunk> toChunkQueue(StreamingOutputCallRequest request) {
/external/grpc-grpc-java/interop-testing/src/generated/main/grpc/io/grpc/testing/integration/
DTestServiceGrpc.java130 … volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest,
135 requestType = io.grpc.testing.integration.Messages.StreamingOutputCallRequest.class,
138 …ic static io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest,
140 …io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest, io.grpc.… in getStreamingOutputCallMethod()
145 …io.grpc.MethodDescriptor.<io.grpc.testing.integration.Messages.StreamingOutputCallRequest, io.grpc… in getStreamingOutputCallMethod()
151 … io.grpc.testing.integration.Messages.StreamingOutputCallRequest.getDefaultInstance())) in getStreamingOutputCallMethod()
194 … volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest,
199 requestType = io.grpc.testing.integration.Messages.StreamingOutputCallRequest.class,
202 …ic static io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest,
204 …io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest, io.grpc.… in getFullDuplexCallMethod()
[all …]
/external/grpc-grpc-java/compiler/src/testNano/golden/
DTestService.java.txt65 …ic volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest,
68 …blic static io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest,
70 …io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest, io.grpc.te…
75 …io.grpc.MethodDescriptor.<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest, io.grpc.t…
80 …pc.protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest>marshall…
81 …new NanoFactory<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest>(ARG_IN_METHOD_STREA…
121 …ic volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest,
124 …blic static io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest,
126 …io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest, io.grpc.te…
131 …io.grpc.MethodDescriptor.<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest, io.grpc.t…
[all …]
/external/grpc-grpc-java/compiler/src/testLite/golden/
DTestService.java.txt64 … static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
69 requestType = io.grpc.testing.compiler.Test.StreamingOutputCallRequest.class,
72 public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
74 …io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing…
79 …io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testin…
85 io.grpc.testing.compiler.Test.StreamingOutputCallRequest.getDefaultInstance()))
126 … static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
131 requestType = io.grpc.testing.compiler.Test.StreamingOutputCallRequest.class,
134 public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
136 …io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing…
[all …]
/external/grpc-grpc-java/compiler/src/test/golden/
DTestService.java.txt65 … static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
70 requestType = io.grpc.testing.compiler.Test.StreamingOutputCallRequest.class,
73 public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
75 …io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing…
80 …io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testin…
86 io.grpc.testing.compiler.Test.StreamingOutputCallRequest.getDefaultInstance()))
129 … static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
134 requestType = io.grpc.testing.compiler.Test.StreamingOutputCallRequest.class,
137 public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
139 …io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing…
[all …]
/external/grpc-grpc/src/ruby/pb/src/proto/grpc/testing/
Dtest_services_pb.rb48 rpc :StreamingOutputCall, StreamingOutputCallRequest, stream(StreamingOutputCallResponse)
55 rpc :FullDuplexCall, stream(StreamingOutputCallRequest), stream(StreamingOutputCallResponse)
60 rpc :HalfDuplexCall, stream(StreamingOutputCallRequest), stream(StreamingOutputCallResponse)
/external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/
DTestGrpc.cs40 …StreamingOutputCallRequest> __Marshaller_grpc_testing_StreamingOutputCallRequest = grpc::Marshalle…
66 …StreamingOutputCallRequest, global::Grpc.Testing.StreamingOutputCallResponse> __Method_StreamingOu…
80 …StreamingOutputCallRequest, global::Grpc.Testing.StreamingOutputCallResponse> __Method_FullDuplexC…
87 …StreamingOutputCallRequest, global::Grpc.Testing.StreamingOutputCallResponse> __Method_HalfDuplexC…
153 ….Threading.Tasks.Task StreamingOutputCall(global::Grpc.Testing.StreamingOutputCallRequest request,… in StreamingOutputCall()
179 …k FullDuplexCall(grpc::IAsyncStreamReader<global::Grpc.Testing.StreamingOutputCallRequest> request… in FullDuplexCall()
194 …k HalfDuplexCall(grpc::IAsyncStreamReader<global::Grpc.Testing.StreamingOutputCallRequest> request… in HalfDuplexCall()
385 …ngOutputCallResponse> StreamingOutputCall(global::Grpc.Testing.StreamingOutputCallRequest request,… in StreamingOutputCall()
396 …ngOutputCallResponse> StreamingOutputCall(global::Grpc.Testing.StreamingOutputCallRequest request,… in StreamingOutputCall()
431 …public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.StreamingOutputCallRequest, glo… in FullDuplexCall()
[all …]
DTestServiceImpl.cs49 …public override async Task StreamingOutputCall(StreamingOutputCallRequest request, IServerStreamWr… in StreamingOutputCall()
74 …public override async Task FullDuplexCall(IAsyncStreamReader<StreamingOutputCallRequest> requestSt… in FullDuplexCall()
89 …public override Task HalfDuplexCall(IAsyncStreamReader<StreamingOutputCallRequest> requestStream, … in HalfDuplexCall()
DInteropClient.cs246 var request = new StreamingOutputCallRequest in RunServerStreamingAsync()
265 await call.RequestStream.WriteAsync(new StreamingOutputCallRequest in RunPingPongAsync()
274 await call.RequestStream.WriteAsync(new StreamingOutputCallRequest in RunPingPongAsync()
283 await call.RequestStream.WriteAsync(new StreamingOutputCallRequest in RunPingPongAsync()
292 await call.RequestStream.WriteAsync(new StreamingOutputCallRequest in RunPingPongAsync()
424 await call.RequestStream.WriteAsync(new StreamingOutputCallRequest in RunCancelAfterFirstResponseAsync()
458 …await call.RequestStream.WriteAsync(new StreamingOutputCallRequest { Payload = CreateZerosPayload(… in RunTimeoutOnSleepingServerAsync()
506 var request = new StreamingOutputCallRequest in RunCustomMetadataAsync()
548 var request = new StreamingOutputCallRequest { ResponseStatus = echoStatus }; in RunStatusCodeAndMessageAsync()
DMetadataCredentialsTest.cs112 var call = client.StreamingOutputCall(new StreamingOutputCallRequest { }); in MetadataCredentials_Composed()
134 var call = client.StreamingOutputCall(new StreamingOutputCallRequest{ }, in MetadataCredentials_ComposedPerCall()
179 …public override async Task StreamingOutputCall(StreamingOutputCallRequest request, IServerStreamWr… in StreamingOutputCall()
/external/grpc-grpc/test/cpp/interop/
Dinterop_server.cc64 using grpc::testing::StreamingOutputCallRequest;
194 ServerContext* context, const StreamingOutputCallRequest* request, in StreamingOutputCall()
256 StreamingOutputCallRequest>* stream) { in FullDuplexCall()
258 StreamingOutputCallRequest request; in FullDuplexCall()
292 StreamingOutputCallRequest>* stream) { in HalfDuplexCall()
293 std::vector<StreamingOutputCallRequest> requests; in HalfDuplexCall()
294 StreamingOutputCallRequest request; in HalfDuplexCall()
Dinterop_client.cc425 StreamingOutputCallRequest request; in DoResponseStreaming()
530 StreamingOutputCallRequest request; in DoServerCompressedStreaming()
589 StreamingOutputCallRequest request; in DoResponseStreamingWithSlowConsumer()
632 std::unique_ptr<ClientReaderWriter<StreamingOutputCallRequest, in DoHalfDuplex()
636 StreamingOutputCallRequest request; in DoHalfDuplex()
679 std::unique_ptr<ClientReaderWriter<StreamingOutputCallRequest, in DoPingPong()
683 StreamingOutputCallRequest request; in DoPingPong()
746 std::unique_ptr<ClientReaderWriter<StreamingOutputCallRequest, in DoCancelAfterFirstResponse()
750 StreamingOutputCallRequest request; in DoCancelAfterFirstResponse()
783 std::unique_ptr<ClientReaderWriter<StreamingOutputCallRequest, in DoTimeoutOnSleepingServer()
[all …]
/external/grpc-grpc-java/compiler/src/test/proto/grpc/testing/compiler/
Dtest.proto35 message StreamingOutputCallRequest { message
49 rpc StreamingOutputCall(StreamingOutputCallRequest)
60 rpc FullBidiCall(stream StreamingOutputCallRequest)
67 rpc HalfBidiCall(stream StreamingOutputCallRequest)
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
DConcurrencyTest.java31 import io.grpc.testing.integration.Messages.StreamingOutputCallRequest;
113 StreamingOutputCallRequest.Builder requestBuilder = StreamingOutputCallRequest.newBuilder() in run()
120 StreamingOutputCallRequest request = requestBuilder.build(); in run()
DHttp2OkHttpTest.java117 Messages.StreamingOutputCallRequest.Builder requestBuilder = in receivedDataForFinishedStream()
118 Messages.StreamingOutputCallRequest.newBuilder() in receivedDataForFinishedStream()
125 StreamObserver<Messages.StreamingOutputCallRequest> requestStream = in receivedDataForFinishedStream()
127 Messages.StreamingOutputCallRequest request = requestBuilder.build(); in receivedDataForFinishedStream()
DNettyFlowControlTest.java33 import io.grpc.testing.integration.Messages.StreamingOutputCallRequest;
137 StreamingOutputCallRequest.Builder builder = StreamingOutputCallRequest.newBuilder() in doTest()
143 StreamingOutputCallRequest request = builder.build(); in doTest()
/external/grpc-grpc/src/python/grpcio_tests/tests/protoc_plugin/protos/service/
Dtest_service.proto29 rpc StreamingOutputCall(StreamingOutputCallRequest)
40 rpc FullDuplexCall(stream StreamingOutputCallRequest)
47 rpc HalfDuplexCall(stream StreamingOutputCallRequest)
/external/grpc-grpc/src/objective-c/tests/RemoteTestClient/
Dtest.proto37 rpc StreamingOutputCall(StreamingOutputCallRequest)
48 rpc FullDuplexCall(stream StreamingOutputCallRequest)
55 rpc HalfDuplexCall(stream StreamingOutputCallRequest)
/external/grpc-grpc/src/objective-c/examples/RemoteTestClient/
Dtest.proto37 rpc StreamingOutputCall(StreamingOutputCallRequest)
48 rpc FullDuplexCall(stream StreamingOutputCallRequest)
55 rpc HalfDuplexCall(stream StreamingOutputCallRequest)
/external/grpc-grpc/src/php/tests/interop/
Dinterop_client.php268 $request = new Grpc\Testing\StreamingOutputCallRequest();
303 $request = new Grpc\Testing\StreamingOutputCallRequest();
363 $request = new Grpc\Testing\StreamingOutputCallRequest();
383 $request = new Grpc\Testing\StreamingOutputCallRequest();
441 $streaming_request = new Grpc\Testing\StreamingOutputCallRequest();
488 $streaming_request = new Grpc\Testing\StreamingOutputCallRequest();
/external/grpc-grpc/src/python/grpcio_tests/tests/interop/
Dmethods.py180 request = messages_pb2.StreamingOutputCallRequest(
251 request = messages_pb2.StreamingOutputCallRequest(
290 request = messages_pb2.StreamingOutputCallRequest(
315 request = messages_pb2.StreamingOutputCallRequest(
356 request = messages_pb2.StreamingOutputCallRequest(
407 request = messages_pb2.StreamingOutputCallRequest(
/external/grpc-grpc/src/proto/grpc/testing/
Dtest.proto42 rpc StreamingOutputCall(StreamingOutputCallRequest)
53 rpc FullDuplexCall(stream StreamingOutputCallRequest)
60 rpc HalfDuplexCall(stream StreamingOutputCallRequest)
/external/grpc-grpc-java/interop-testing/src/main/proto/grpc/testing/
Dtest.proto41 rpc StreamingOutputCall(StreamingOutputCallRequest)
52 rpc FullDuplexCall(stream StreamingOutputCallRequest)
59 rpc HalfDuplexCall(stream StreamingOutputCallRequest)
/external/grpc-grpc/src/python/grpcio_tests/tests/protoc_plugin/
D_python_plugin_test.py201 request = request_pb2.StreamingOutputCallRequest()
210 request = request_pb2.StreamingOutputCallRequest()
213 request = request_pb2.StreamingOutputCallRequest()
454 request = request_pb2.StreamingOutputCallRequest()
457 request = request_pb2.StreamingOutputCallRequest()
485 request = request_pb2.StreamingOutputCallRequest()

12