Home
last modified time | relevance | path

Searched refs:StreamingOutputCallResponse (Results 1 – 25 of 42) sorted by relevance

12

/external/grpc-grpc-java/interop-testing/src/generated/main/grpc/io/grpc/testing/integration/
DTestServiceGrpc.java131 … io.grpc.testing.integration.Messages.StreamingOutputCallResponse> getStreamingOutputCallMethod;
136 responseType = io.grpc.testing.integration.Messages.StreamingOutputCallResponse.class,
139 … io.grpc.testing.integration.Messages.StreamingOutputCallResponse> getStreamingOutputCallMethod() { in getStreamingOutputCallMethod()
140 …reamingOutputCallRequest, io.grpc.testing.integration.Messages.StreamingOutputCallResponse> getStr… in getStreamingOutputCallMethod()
145 …reamingOutputCallRequest, io.grpc.testing.integration.Messages.StreamingOutputCallResponse>newBuil… in getStreamingOutputCallMethod()
153 … io.grpc.testing.integration.Messages.StreamingOutputCallResponse.getDefaultInstance())) in getStreamingOutputCallMethod()
195 io.grpc.testing.integration.Messages.StreamingOutputCallResponse> getFullDuplexCallMethod;
200 responseType = io.grpc.testing.integration.Messages.StreamingOutputCallResponse.class,
203 io.grpc.testing.integration.Messages.StreamingOutputCallResponse> getFullDuplexCallMethod() { in getFullDuplexCallMethod()
204 …reamingOutputCallRequest, io.grpc.testing.integration.Messages.StreamingOutputCallResponse> getFul… in getFullDuplexCallMethod()
[all …]
/external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/
DTestServiceImpl.cs49 …utCall(StreamingOutputCallRequest request, IServerStreamWriter<StreamingOutputCallResponse> respon… in StreamingOutputCall()
56 …var response = new StreamingOutputCallResponse { Payload = CreateZerosPayload(responseParam.Size) … in StreamingOutputCall()
74 …StreamingOutputCallRequest> requestStream, IServerStreamWriter<StreamingOutputCallResponse> respon… in FullDuplexCall()
83 …var response = new StreamingOutputCallResponse { Payload = CreateZerosPayload(responseParam.Size) … in FullDuplexCall()
89 …StreamingOutputCallRequest> requestStream, IServerStreamWriter<StreamingOutputCallResponse> respon… in HalfDuplexCall()
DTestGrpc.cs41StreamingOutputCallResponse> __Marshaller_grpc_testing_StreamingOutputCallResponse = grpc::Marshal…
66StreamingOutputCallResponse> __Method_StreamingOutputCall = new grpc::Method<global::Grpc.Testing.…
80StreamingOutputCallResponse> __Method_FullDuplexCall = new grpc::Method<global::Grpc.Testing.Strea…
87StreamingOutputCallResponse> __Method_HalfDuplexCall = new grpc::Method<global::Grpc.Testing.Strea…
153 …equest request, grpc::IServerStreamWriter<global::Grpc.Testing.StreamingOutputCallResponse> respon… in StreamingOutputCall()
179 … requestStream, grpc::IServerStreamWriter<global::Grpc.Testing.StreamingOutputCallResponse> respon… in FullDuplexCall()
194 … requestStream, grpc::IServerStreamWriter<global::Grpc.Testing.StreamingOutputCallResponse> respon… in HalfDuplexCall()
385 …ic virtual grpc::AsyncServerStreamingCall<global::Grpc.Testing.StreamingOutputCallResponse> Stream… in StreamingOutputCall()
396 …ic virtual grpc::AsyncServerStreamingCall<global::Grpc.Testing.StreamingOutputCallResponse> Stream… in StreamingOutputCall()
431 …:Grpc.Testing.StreamingOutputCallRequest, global::Grpc.Testing.StreamingOutputCallResponse> FullDu… in FullDuplexCall()
[all …]
DMessages.cs70 …TypeInfo(typeof(global::Grpc.Testing.StreamingOutputCallResponse), global::Grpc.Testing.StreamingO… in MessagesReflection()
1901 …public sealed partial class StreamingOutputCallResponse : pb::IMessage<StreamingOutputCallResponse class
1902 …essageParser<StreamingOutputCallResponse> _parser = new pb::MessageParser<StreamingOutputCallRespo…
1905 public static pb::MessageParser<StreamingOutputCallResponse> Parser { get { return _parser; } }
1918 public StreamingOutputCallResponse() { in StreamingOutputCallResponse() method in Grpc.Testing.StreamingOutputCallResponse
1925 public StreamingOutputCallResponse(StreamingOutputCallResponse other) : this() { in StreamingOutputCallResponse() method in Grpc.Testing.StreamingOutputCallResponse
1931 public StreamingOutputCallResponse Clone() { in Clone()
1932 return new StreamingOutputCallResponse(this); in Clone()
1951 return Equals(other as StreamingOutputCallResponse); in Equals()
1955 public bool Equals(StreamingOutputCallResponse other) { in Equals()
[all …]
DMetadataCredentialsTest.cs179 …utCall(StreamingOutputCallRequest request, IServerStreamWriter<StreamingOutputCallResponse> respon… in StreamingOutputCall()
187 await responseStream.WriteAsync(new StreamingOutputCallResponse()); in StreamingOutputCall()
/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/
DAbstractInteropTest.java96 import io.grpc.testing.integration.Messages.StreamingOutputCallResponse;
513 final List<StreamingOutputCallResponse> goldenResponses = Arrays.asList( in serverStreaming()
514 StreamingOutputCallResponse.newBuilder() in serverStreaming()
519 StreamingOutputCallResponse.newBuilder() in serverStreaming()
524 StreamingOutputCallResponse.newBuilder() in serverStreaming()
529 StreamingOutputCallResponse.newBuilder() in serverStreaming()
535 StreamRecorder<StreamingOutputCallResponse> recorder = StreamRecorder.create(); in serverStreaming()
649 final List<StreamingOutputCallResponse> goldenResponses = in serverCompressedStreaming()
651 StreamingOutputCallResponse.newBuilder() in serverCompressedStreaming()
654 StreamingOutputCallResponse.newBuilder() in serverCompressedStreaming()
[all …]
DTestServiceImpl.java39 import io.grpc.testing.integration.Messages.StreamingOutputCallResponse;
136 StreamObserver<StreamingOutputCallResponse> responseObserver) { in streamingOutputCall()
176 final StreamObserver<Messages.StreamingOutputCallResponse> responseObserver) { in fullDuplexCall()
212 final StreamObserver<Messages.StreamingOutputCallResponse> responseObserver) {
242 private final StreamObserver<StreamingOutputCallResponse> responseStream;
279 public ResponseDispatcher(StreamObserver<StreamingOutputCallResponse> responseStream) {
421 private StreamingOutputCallResponse toResponse() {
422 StreamingOutputCallResponse.Builder responseBuilder =
423 StreamingOutputCallResponse.newBuilder();
/external/grpc-grpc-java/compiler/src/testNano/golden/
DTestService.java.txt66 io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod;
69 … io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod() {
70 …StreamingOutputCallRequest, io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> getStr…
75 …StreamingOutputCallRequest, io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse>newBuil…
82 …pc.protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse>marshal…
83 …new NanoFactory<io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse>(ARG_OUT_METHOD_STR…
122 io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> getFullBidiCallMethod;
125 io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> getFullBidiCallMethod() {
126 …StreamingOutputCallRequest, io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> getFul…
131 …StreamingOutputCallRequest, io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse>newBuil…
[all …]
/external/grpc-grpc-java/compiler/src/testLite/golden/
DTestService.java.txt65 io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod;
70 responseType = io.grpc.testing.compiler.Test.StreamingOutputCallResponse.class,
73 io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod() {
74 …Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getStr…
79 …Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse>newBuil…
87 io.grpc.testing.compiler.Test.StreamingOutputCallResponse.getDefaultInstance()))
127 io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getFullBidiCallMethod;
132 responseType = io.grpc.testing.compiler.Test.StreamingOutputCallResponse.class,
135 io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getFullBidiCallMethod() {
136 …Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getFul…
[all …]
/external/grpc-grpc-java/compiler/src/test/golden/
DTestService.java.txt66 io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod;
71 responseType = io.grpc.testing.compiler.Test.StreamingOutputCallResponse.class,
74 io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod() {
75 …Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getStr…
80 …Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse>newBuil…
88 io.grpc.testing.compiler.Test.StreamingOutputCallResponse.getDefaultInstance()))
130 io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getFullBidiCallMethod;
135 responseType = io.grpc.testing.compiler.Test.StreamingOutputCallResponse.class,
138 io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getFullBidiCallMethod() {
139 …Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getFul…
[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/test/cpp/interop/
Dinterop_client.cc430 StreamingOutputCallResponse response; in DoResponseStreaming()
431 std::unique_ptr<ClientReader<StreamingOutputCallResponse>> stream( in DoResponseStreaming()
546 std::unique_ptr<ClientReader<StreamingOutputCallResponse>> stream( in DoServerCompressedStreaming()
550 StreamingOutputCallResponse response; in DoServerCompressedStreaming()
595 StreamingOutputCallResponse response; in DoResponseStreamingWithSlowConsumer()
596 std::unique_ptr<ClientReader<StreamingOutputCallResponse>> stream( in DoResponseStreamingWithSlowConsumer()
633 StreamingOutputCallResponse>> in DoHalfDuplex()
649 StreamingOutputCallResponse response; in DoHalfDuplex()
680 StreamingOutputCallResponse>> in DoPingPong()
686 StreamingOutputCallResponse response; in DoPingPong()
[all …]
Dinterop_server.cc65 using grpc::testing::StreamingOutputCallResponse;
195 ServerWriter<StreamingOutputCallResponse>* writer) { in StreamingOutputCall()
196 StreamingOutputCallResponse response; in StreamingOutputCall()
255 ServerReaderWriter<StreamingOutputCallResponse, in FullDuplexCall() argument
259 StreamingOutputCallResponse response; in FullDuplexCall()
291 ServerReaderWriter<StreamingOutputCallResponse, in HalfDuplexCall() argument
299 StreamingOutputCallResponse response; in HalfDuplexCall()
/external/grpc-grpc-java/compiler/src/test/proto/grpc/testing/compiler/
Dtest.proto38 message StreamingOutputCallResponse { message
50 returns (stream StreamingOutputCallResponse);
61 returns (stream StreamingOutputCallResponse);
68 returns (stream StreamingOutputCallResponse);
/external/grpc-grpc/src/python/grpcio_tests/tests/protoc_plugin/protos/service/
Dtest_service.proto30 returns (stream StreamingOutputCallResponse);
41 returns (stream StreamingOutputCallResponse);
48 returns (stream StreamingOutputCallResponse);
/external/grpc-grpc/src/objective-c/tests/RemoteTestClient/
Dtest.proto38 returns (stream StreamingOutputCallResponse);
49 returns (stream StreamingOutputCallResponse);
56 returns (stream StreamingOutputCallResponse);
/external/grpc-grpc/src/objective-c/examples/RemoteTestClient/
Dtest.proto38 returns (stream StreamingOutputCallResponse);
49 returns (stream StreamingOutputCallResponse);
56 returns (stream StreamingOutputCallResponse);
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
DConcurrencyTest.java32 import io.grpc.testing.integration.Messages.StreamingOutputCallResponse;
72 implements StreamObserver<StreamingOutputCallResponse> {
90 public void onNext(StreamingOutputCallResponse response) { in onNext()
DNettyFlowControlTest.java34 import io.grpc.testing.integration.Messages.StreamingOutputCallResponse;
194 private static class TestStreamObserver implements StreamObserver<StreamingOutputCallResponse> {
208 public void onNext(StreamingOutputCallResponse value) { in onNext()
/external/grpc-grpc/src/proto/grpc/testing/
Dtest.proto43 returns (stream StreamingOutputCallResponse);
54 returns (stream StreamingOutputCallResponse);
61 returns (stream StreamingOutputCallResponse);
/external/grpc-grpc-java/interop-testing/src/main/proto/grpc/testing/
Dtest.proto42 returns (stream StreamingOutputCallResponse);
53 returns (stream StreamingOutputCallResponse);
60 returns (stream StreamingOutputCallResponse);
/external/rust/crates/grpcio-sys/grpc/src/proto/grpc/testing/
Dtest.proto43 returns (stream StreamingOutputCallResponse);
54 returns (stream StreamingOutputCallResponse);
61 returns (stream StreamingOutputCallResponse);
/external/grpc-grpc/src/ruby/pb/test/
Dserver.rb150 cls = StreamingOutputCallResponse
194 cls = StreamingOutputCallResponse
/external/grpc-grpc/src/php/tests/qps/generated_code/Grpc/Testing/
DStreamingOutputCallResponse.php16 class StreamingOutputCallResponse extends \Google\Protobuf\Internal\Message class
/external/grpc-grpc/src/python/grpcio_tests/tests/protoc_plugin/protos/responses/
Dtest_responses.proto30 message StreamingOutputCallResponse { message

12