Home
last modified time | relevance | path

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

123

/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/
DAbstractInteropTest.java93 import io.grpc.testing.integration.Messages.StreamingOutputCallRequest;
618 final StreamingOutputCallRequest request = StreamingOutputCallRequest.newBuilder() in serverStreaming()
749 final StreamingOutputCallRequest request = in serverCompressedStreaming()
750 StreamingOutputCallRequest.newBuilder() in serverCompressedStreaming()
778 final List<StreamingOutputCallRequest> requests = Arrays.asList( in pingPong()
779 StreamingOutputCallRequest.newBuilder() in pingPong()
785 StreamingOutputCallRequest.newBuilder() in pingPong()
791 StreamingOutputCallRequest.newBuilder() in pingPong()
797 StreamingOutputCallRequest.newBuilder() in pingPong()
822 StreamObserver<StreamingOutputCallRequest> requestObserver in pingPong()
[all …]
DTestServiceImpl.java40 import io.grpc.testing.integration.Messages.StreamingOutputCallRequest;
168 public void streamingOutputCall(StreamingOutputCallRequest request, in streamingOutputCall()
208 public StreamObserver<Messages.StreamingOutputCallRequest> fullDuplexCall( in fullDuplexCall()
211 return new StreamObserver<StreamingOutputCallRequest>() { in fullDuplexCall()
215 public void onNext(StreamingOutputCallRequest request) { in fullDuplexCall()
269 public StreamObserver<Messages.StreamingOutputCallRequest> halfDuplexCall(
273 return new StreamObserver<StreamingOutputCallRequest>() {
275 public void onNext(StreamingOutputCallRequest request) {
442 public Queue<Chunk> toChunkQueue(StreamingOutputCallRequest request) {
/external/grpc-grpc-java/android-interop-testing/src/generated/release/grpc/io/grpc/testing/integration/
DTestServiceGrpc.java112 … volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest,
117 requestType = io.grpc.testing.integration.Messages.StreamingOutputCallRequest.class,
120 …ic static io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest,
122 …io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest, io.grpc.… in getStreamingOutputCallMethod()
127 …io.grpc.MethodDescriptor.<io.grpc.testing.integration.Messages.StreamingOutputCallRequest, io.grpc… in getStreamingOutputCallMethod()
132 … io.grpc.testing.integration.Messages.StreamingOutputCallRequest.getDefaultInstance())) in getStreamingOutputCallMethod()
172 … volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest,
177 requestType = io.grpc.testing.integration.Messages.StreamingOutputCallRequest.class,
180 …ic static io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest,
182 …io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest, io.grpc.… in getFullDuplexCallMethod()
[all …]
/external/grpc-grpc-java/android-interop-testing/src/generated/debug/grpc/io/grpc/testing/integration/
DTestServiceGrpc.java112 … volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest,
117 requestType = io.grpc.testing.integration.Messages.StreamingOutputCallRequest.class,
120 …ic static io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest,
122 …io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest, io.grpc.… in getStreamingOutputCallMethod()
127 …io.grpc.MethodDescriptor.<io.grpc.testing.integration.Messages.StreamingOutputCallRequest, io.grpc… in getStreamingOutputCallMethod()
132 … io.grpc.testing.integration.Messages.StreamingOutputCallRequest.getDefaultInstance())) in getStreamingOutputCallMethod()
172 … volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest,
177 requestType = io.grpc.testing.integration.Messages.StreamingOutputCallRequest.class,
180 …ic static io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest,
182 …io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest, io.grpc.… in getFullDuplexCallMethod()
[all …]
/external/grpc-grpc-java/interop-testing/src/generated/main/grpc/io/grpc/testing/integration/
DTestServiceGrpc.java115 … volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest,
120 requestType = io.grpc.testing.integration.Messages.StreamingOutputCallRequest.class,
123 …ic static io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest,
125 …io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest, io.grpc.… in getStreamingOutputCallMethod()
130 …io.grpc.MethodDescriptor.<io.grpc.testing.integration.Messages.StreamingOutputCallRequest, io.grpc… in getStreamingOutputCallMethod()
135 … io.grpc.testing.integration.Messages.StreamingOutputCallRequest.getDefaultInstance())) in getStreamingOutputCallMethod()
177 … volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest,
182 requestType = io.grpc.testing.integration.Messages.StreamingOutputCallRequest.class,
185 …ic static io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest,
187 …io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest, io.grpc.… in getFullDuplexCallMethod()
[all …]
/external/grpc-grpc/src/python/grpcio_tests/tests_aio/unit/
Dclient_unary_stream_interceptor_test.py80 request = messages_pb2.StreamingOutputCallRequest()
130 request = messages_pb2.StreamingOutputCallRequest()
163 request = messages_pb2.StreamingOutputCallRequest()
201 request = messages_pb2.StreamingOutputCallRequest()
239 request = messages_pb2.StreamingOutputCallRequest()
275 request = messages_pb2.StreamingOutputCallRequest()
306 request = messages_pb2.StreamingOutputCallRequest()
342 request = messages_pb2.StreamingOutputCallRequest()
364 request = messages_pb2.StreamingOutputCallRequest()
398 request = messages_pb2.StreamingOutputCallRequest()
[all …]
Dcall_test.py229 request = messages_pb2.StreamingOutputCallRequest()
247 request = messages_pb2.StreamingOutputCallRequest()
277 request = messages_pb2.StreamingOutputCallRequest()
305 request = messages_pb2.StreamingOutputCallRequest()
334 request = messages_pb2.StreamingOutputCallRequest()
363 request = messages_pb2.StreamingOutputCallRequest()
389 request = messages_pb2.StreamingOutputCallRequest()
432 request = messages_pb2.StreamingOutputCallRequest()
473 request = messages_pb2.StreamingOutputCallRequest()
503 request = messages_pb2.StreamingOutputCallRequest()
[all …]
Dclient_stream_stream_interceptor_test.py82 request = messages_pb2.StreamingOutputCallRequest()
132 request = messages_pb2.StreamingOutputCallRequest()
177 request = messages_pb2.StreamingOutputCallRequest()
Dsecure_call_test.py89 request = messages_pb2.StreamingOutputCallRequest()
114 _STREAM_OUTPUT_REQUEST_ONE_RESPONSE = messages_pb2.StreamingOutputCallRequest()
/external/grpc-grpc-java/compiler/src/test/golden/
DTestService.java.txt52 … static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
57 requestType = io.grpc.testing.compiler.Test.StreamingOutputCallRequest.class,
60 public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
62 …io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing…
67 …io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testin…
72 io.grpc.testing.compiler.Test.StreamingOutputCallRequest.getDefaultInstance()))
114 … static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
119 requestType = io.grpc.testing.compiler.Test.StreamingOutputCallRequest.class,
122 public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
124 …io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing…
[all …]
/external/grpc-grpc-java/compiler/src/testLite/golden/
DTestService.java.txt51 … static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
56 requestType = io.grpc.testing.compiler.Test.StreamingOutputCallRequest.class,
59 public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
61 …io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing…
66 …io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testin…
71 io.grpc.testing.compiler.Test.StreamingOutputCallRequest.getDefaultInstance()))
111 … static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
116 requestType = io.grpc.testing.compiler.Test.StreamingOutputCallRequest.class,
119 public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
121 …io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing…
[all …]
/external/grpc-grpc/test/cpp/interop/
Dinterop_client.cc512 StreamingOutputCallRequest request; in DoResponseStreaming()
613 StreamingOutputCallRequest request; in DoServerCompressedStreaming()
668 StreamingOutputCallRequest request; in DoResponseStreamingWithSlowConsumer()
711 std::unique_ptr<ClientReaderWriter<StreamingOutputCallRequest, in DoHalfDuplex()
715 StreamingOutputCallRequest request; in DoHalfDuplex()
758 std::unique_ptr<ClientReaderWriter<StreamingOutputCallRequest, in DoPingPong()
762 StreamingOutputCallRequest request; in DoPingPong()
825 std::unique_ptr<ClientReaderWriter<StreamingOutputCallRequest, in DoCancelAfterFirstResponse()
829 StreamingOutputCallRequest request; in DoCancelAfterFirstResponse()
862 std::unique_ptr<ClientReaderWriter<StreamingOutputCallRequest, in DoTimeoutOnSleepingServer()
[all …]
Dinterop_server.cc68 using grpc::testing::StreamingOutputCallRequest;
232 ServerContext* context, const StreamingOutputCallRequest* request, in StreamingOutputCall()
294 StreamingOutputCallRequest>* stream) override { in FullDuplexCall()
296 StreamingOutputCallRequest request; in FullDuplexCall()
343 StreamingOutputCallRequest>* stream) override { in HalfDuplexCall()
344 std::vector<StreamingOutputCallRequest> requests; in HalfDuplexCall()
345 StreamingOutputCallRequest request; in HalfDuplexCall()
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
DConcurrencyTest.java34 import io.grpc.testing.integration.Messages.StreamingOutputCallRequest;
111 StreamingOutputCallRequest.Builder requestBuilder = StreamingOutputCallRequest.newBuilder(); in run()
117 StreamingOutputCallRequest request = requestBuilder.build(); in run()
DHttp2OkHttpTest.java120 Messages.StreamingOutputCallRequest.Builder requestBuilder = in receivedDataForFinishedStream()
121 Messages.StreamingOutputCallRequest.newBuilder(); in receivedDataForFinishedStream()
127 StreamObserver<Messages.StreamingOutputCallRequest> requestStream = in receivedDataForFinishedStream()
129 Messages.StreamingOutputCallRequest request = requestBuilder.build(); in receivedDataForFinishedStream()
DNettyFlowControlTest.java37 import io.grpc.testing.integration.Messages.StreamingOutputCallRequest;
134 StreamingOutputCallRequest.Builder builder = StreamingOutputCallRequest.newBuilder() in doTest()
140 StreamingOutputCallRequest request = builder.build(); in doTest()
/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/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/python/grpcio_tests/tests/interop/
Dmethods.py136 request = messages_pb2.StreamingOutputCallRequest(
209 request = messages_pb2.StreamingOutputCallRequest(
251 request = messages_pb2.StreamingOutputCallRequest(
278 request = messages_pb2.StreamingOutputCallRequest(
321 request = messages_pb2.StreamingOutputCallRequest(
390 request = messages_pb2.StreamingOutputCallRequest(
/external/grpc-grpc/src/python/grpcio_tests/tests_aio/interop/
Dmethods.py148 request = messages_pb2.StreamingOutputCallRequest(
183 request = messages_pb2.StreamingOutputCallRequest(
228 request = messages_pb2.StreamingOutputCallRequest(
255 request = messages_pb2.StreamingOutputCallRequest(
299 request = messages_pb2.StreamingOutputCallRequest(
366 request = messages_pb2.StreamingOutputCallRequest(
/external/grpc-grpc/src/python/grpcio_tests/tests/protoc_plugin/
D_python_plugin_test.py206 request = request_pb2.StreamingOutputCallRequest()
215 request = request_pb2.StreamingOutputCallRequest()
218 request = request_pb2.StreamingOutputCallRequest()
491 request = request_pb2.StreamingOutputCallRequest()
494 request = request_pb2.StreamingOutputCallRequest()
524 request = request_pb2.StreamingOutputCallRequest()
673 request = request_pb2.StreamingOutputCallRequest()
676 request = request_pb2.StreamingOutputCallRequest()
/external/grpc-grpc/src/php/tests/interop/
Dinterop_client.php377 $request = new Grpc\Testing\StreamingOutputCallRequest();
412 $request = new Grpc\Testing\StreamingOutputCallRequest();
472 $request = new Grpc\Testing\StreamingOutputCallRequest();
492 $request = new Grpc\Testing\StreamingOutputCallRequest();
550 $streaming_request = new Grpc\Testing\StreamingOutputCallRequest();
597 $streaming_request = new Grpc\Testing\StreamingOutputCallRequest();
/external/grpc-grpc-java/interop-testing/src/main/proto/grpc/testing/
Dtest.proto44 rpc StreamingOutputCall(StreamingOutputCallRequest)
55 rpc FullDuplexCall(stream StreamingOutputCallRequest)
62 rpc HalfDuplexCall(stream StreamingOutputCallRequest)

123