Home
last modified time | relevance | path

Searched refs:StreamingInputCallResponse (Results 1 – 25 of 40) sorted by relevance

12

/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
DMoreInProcessTest.java31 import io.grpc.testing.integration.Messages.StreamingInputCallResponse;
78 final StreamingInputCallResponse fakeResponse = in asyncClientStreaming_serverResponsePriorToRequest()
79 StreamingInputCallResponse.newBuilder().setAggregatedPayloadSize(100).build(); in asyncClientStreaming_serverResponsePriorToRequest()
83 StreamObserver<StreamingInputCallResponse> responseObserver) { in asyncClientStreaming_serverResponsePriorToRequest()
105 final AtomicReference<StreamingInputCallResponse> responseRef = in asyncClientStreaming_serverResponsePriorToRequest()
106 new AtomicReference<StreamingInputCallResponse>(); in asyncClientStreaming_serverResponsePriorToRequest()
108 StreamObserver<StreamingInputCallResponse> responseObserver = in asyncClientStreaming_serverResponsePriorToRequest()
109 new StreamObserver<StreamingInputCallResponse>() { in asyncClientStreaming_serverResponsePriorToRequest()
111 public void onNext(StreamingInputCallResponse response) { in asyncClientStreaming_serverResponsePriorToRequest()
142 StreamObserver<StreamingInputCallResponse> responseObserver) { in asyncClientStreaming_serverErrorPriorToRequest()
[all …]
/external/grpc-grpc-java/compiler/src/testNano/golden/
DTestService.java.txt94 io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse> getStreamingInputCallMethod;
97 io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse> getStreamingInputCallMethod() {
98 ….StreamingInputCallRequest, io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse> getStre…
103 ….StreamingInputCallRequest, io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse>newBuild…
110 …pc.protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse>marshall…
111 …new NanoFactory<io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse>(ARG_OUT_METHOD_STRE…
178 io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse> getImportMethod;
181 io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse> getImportMethod() {
182 ….StreamingInputCallRequest, io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse> getImpo…
187 ….StreamingInputCallRequest, io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse>newBuild…
[all …]
/external/grpc-grpc-java/compiler/src/testLite/golden/
DTestService.java.txt96 io.grpc.testing.compiler.Test.StreamingInputCallResponse> getStreamingInputCallMethod;
101 responseType = io.grpc.testing.compiler.Test.StreamingInputCallResponse.class,
104 io.grpc.testing.compiler.Test.StreamingInputCallResponse> getStreamingInputCallMethod() {
105 ….Test.StreamingInputCallRequest, io.grpc.testing.compiler.Test.StreamingInputCallResponse> getStre…
110 ….Test.StreamingInputCallRequest, io.grpc.testing.compiler.Test.StreamingInputCallResponse>newBuild…
118 io.grpc.testing.compiler.Test.StreamingInputCallResponse.getDefaultInstance()))
189 io.grpc.testing.compiler.Test.StreamingInputCallResponse> getImportMethod;
194 responseType = io.grpc.testing.compiler.Test.StreamingInputCallResponse.class,
197 io.grpc.testing.compiler.Test.StreamingInputCallResponse> getImportMethod() {
198 ….Test.StreamingInputCallRequest, io.grpc.testing.compiler.Test.StreamingInputCallResponse> getImpo…
[all …]
/external/grpc-grpc-java/compiler/src/test/golden/
DTestService.java.txt98 io.grpc.testing.compiler.Test.StreamingInputCallResponse> getStreamingInputCallMethod;
103 responseType = io.grpc.testing.compiler.Test.StreamingInputCallResponse.class,
106 io.grpc.testing.compiler.Test.StreamingInputCallResponse> getStreamingInputCallMethod() {
107 ….Test.StreamingInputCallRequest, io.grpc.testing.compiler.Test.StreamingInputCallResponse> getStre…
112 ….Test.StreamingInputCallRequest, io.grpc.testing.compiler.Test.StreamingInputCallResponse>newBuild…
120 io.grpc.testing.compiler.Test.StreamingInputCallResponse.getDefaultInstance()))
194 io.grpc.testing.compiler.Test.StreamingInputCallResponse> getImportMethod;
199 responseType = io.grpc.testing.compiler.Test.StreamingInputCallResponse.class,
202 io.grpc.testing.compiler.Test.StreamingInputCallResponse> getImportMethod() {
203 ….Test.StreamingInputCallRequest, io.grpc.testing.compiler.Test.StreamingInputCallResponse> getImpo…
[all …]
/external/grpc-grpc-java/compiler/src/test/proto/grpc/testing/compiler/
Dtest.proto32 message StreamingInputCallResponse { message
55 returns (StreamingInputCallResponse);
72 rpc Import(stream StreamingInputCallRequest) returns (stream StreamingInputCallResponse);
/external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/
DSslCredentialsTest.cs102 …public override async Task<StreamingInputCallResponse> StreamingInputCall(IAsyncStreamReader<Strea… in StreamingInputCall()
112 return new StreamingInputCallResponse { AggregatedPayloadSize = 12345 }; in StreamingInputCall()
DTestServiceImpl.cs61 …public override async Task<StreamingInputCallResponse> StreamingInputCall(IAsyncStreamReader<Strea… in StreamingInputCall()
71 return new StreamingInputCallResponse { AggregatedPayloadSize = sum }; in StreamingInputCall()
DMessages.cs67 …rTypeInfo(typeof(global::Grpc.Testing.StreamingInputCallResponse), global::Grpc.Testing.StreamingI… in MessagesReflection()
1324 …public sealed partial class StreamingInputCallResponse : pb::IMessage<StreamingInputCallResponse> { class
1325 …MessageParser<StreamingInputCallResponse> _parser = new pb::MessageParser<StreamingInputCallRespon…
1328 public static pb::MessageParser<StreamingInputCallResponse> Parser { get { return _parser; } }
1341 public StreamingInputCallResponse() { in StreamingInputCallResponse() method in Grpc.Testing.StreamingInputCallResponse
1348 public StreamingInputCallResponse(StreamingInputCallResponse other) : this() { in StreamingInputCallResponse() method in Grpc.Testing.StreamingInputCallResponse
1354 public StreamingInputCallResponse Clone() { in Clone()
1355 return new StreamingInputCallResponse(this); in Clone()
1374 return Equals(other as StreamingInputCallResponse); in Equals()
1378 public bool Equals(StreamingInputCallResponse other) { in Equals()
[all …]
DTestGrpc.cs43 …StreamingInputCallResponse> __Marshaller_grpc_testing_StreamingInputCallResponse = grpc::Marshalle…
73 …StreamingInputCallResponse> __Method_StreamingInputCall = new grpc::Method<global::Grpc.Testing.St…
165 …rtual global::System.Threading.Tasks.Task<global::Grpc.Testing.StreamingInputCallResponse> Streami… in StreamingInputCall()
408 …::Grpc.Testing.StreamingInputCallRequest, global::Grpc.Testing.StreamingInputCallResponse> Streami… in StreamingInputCall()
418 …::Grpc.Testing.StreamingInputCallRequest, global::Grpc.Testing.StreamingInputCallResponse> Streami… in StreamingInputCall()
/external/grpc-grpc-java/interop-testing/src/generated/main/grpc/io/grpc/testing/integration/
DTestServiceGrpc.java163 io.grpc.testing.integration.Messages.StreamingInputCallResponse> getStreamingInputCallMethod;
168 responseType = io.grpc.testing.integration.Messages.StreamingInputCallResponse.class,
171 … io.grpc.testing.integration.Messages.StreamingInputCallResponse> getStreamingInputCallMethod() { in getStreamingInputCallMethod()
172 …treamingInputCallRequest, io.grpc.testing.integration.Messages.StreamingInputCallResponse> getStre… in getStreamingInputCallMethod()
177 …treamingInputCallRequest, io.grpc.testing.integration.Messages.StreamingInputCallResponse>newBuild… in getStreamingInputCallMethod()
185 … io.grpc.testing.integration.Messages.StreamingInputCallResponse.getDefaultInstance())) in getStreamingInputCallMethod()
371 …io.grpc.stub.StreamObserver<io.grpc.testing.integration.Messages.StreamingInputCallResponse> respo… in streamingInputCall()
446 io.grpc.testing.integration.Messages.StreamingInputCallResponse>( in bindService()
549 …io.grpc.stub.StreamObserver<io.grpc.testing.integration.Messages.StreamingInputCallResponse> respo… in streamingInputCall()
800 ….grpc.stub.StreamObserver<io.grpc.testing.integration.Messages.StreamingInputCallResponse>) respon… in invoke()
/external/grpc-grpc/src/php/tests/qps/generated_code/Grpc/Testing/
DStreamingInputCallResponse.php16 class StreamingInputCallResponse extends \Google\Protobuf\Internal\Message class
/external/grpc-grpc/src/ruby/pb/src/proto/grpc/testing/
Dtest_services_pb.rb51 rpc :StreamingInputCall, stream(StreamingInputCallRequest), StreamingInputCallResponse
Dmessages_pb.rb74 …StreamingInputCallResponse = Google::Protobuf::DescriptorPool.generated_pool.lookup("grpc.testing.… constant
/external/grpc-grpc/src/python/grpcio_tests/tests/protoc_plugin/protos/responses/
Dtest_responses.proto25 message StreamingInputCallResponse { message
/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/
DTestServiceImpl.java37 import io.grpc.testing.integration.Messages.StreamingInputCallResponse;
147 final StreamObserver<Messages.StreamingInputCallResponse> responseObserver) { in streamingInputCall()
158 responseObserver.onNext(StreamingInputCallResponse.newBuilder() in streamingInputCall()
DAbstractInteropTest.java94 import io.grpc.testing.integration.Messages.StreamingInputCallResponse;
561 final StreamingInputCallResponse goldenResponse = StreamingInputCallResponse.newBuilder() in clientStreaming()
565 StreamRecorder<StreamingInputCallResponse> responseObserver = StreamRecorder.create(); in clientStreaming()
598 final StreamingInputCallResponse goldenResponse = in clientCompressedStreaming()
599 StreamingInputCallResponse.newBuilder().setAggregatedPayloadSize(73086).build(); in clientCompressedStreaming()
601 StreamRecorder<StreamingInputCallResponse> responseObserver = StreamRecorder.create(); in clientCompressedStreaming()
757 StreamRecorder<StreamingInputCallResponse> responseObserver = StreamRecorder.create(); in cancelAfterBegin()
762 assertEquals(Arrays.<StreamingInputCallResponse>asList(), responseObserver.getValues()); in cancelAfterBegin()
/external/grpc-grpc/src/ruby/qps/src/proto/grpc/testing/
Dmessages_pb.rb74 …StreamingInputCallResponse = Google::Protobuf::DescriptorPool.generated_pool.lookup("grpc.testing.… constant
/external/grpc-grpc-java/benchmarks/src/generated/main/java/io/grpc/benchmarks/proto/
DMessages.java5648 public static final class StreamingInputCallResponse extends class in Messages
5654 private StreamingInputCallResponse(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) { in StreamingInputCallResponse() method in Messages.StreamingInputCallResponse
5657 private StreamingInputCallResponse() { in StreamingInputCallResponse() method in Messages.StreamingInputCallResponse
5666 private StreamingInputCallResponse( in StreamingInputCallResponse() method in Messages.StreamingInputCallResponse
5718 …pc.benchmarks.proto.Messages.StreamingInputCallResponse.class, io.grpc.benchmarks.proto.Messages.S… in internalGetFieldAccessorTable()
5771 if (!(obj instanceof io.grpc.benchmarks.proto.Messages.StreamingInputCallResponse)) { in equals()
5774 …c.benchmarks.proto.Messages.StreamingInputCallResponse other = (io.grpc.benchmarks.proto.Messages.… in equals()
5797 public static io.grpc.benchmarks.proto.Messages.StreamingInputCallResponse parseFrom( in parseFrom()
5802 public static io.grpc.benchmarks.proto.Messages.StreamingInputCallResponse parseFrom( in parseFrom()
5808 public static io.grpc.benchmarks.proto.Messages.StreamingInputCallResponse parseFrom( in parseFrom()
[all …]
/external/grpc-grpc-java/interop-testing/src/generated/main/java/io/grpc/testing/integration/
DMessages.java5723 public static final class StreamingInputCallResponse extends class in Messages
5729 private StreamingInputCallResponse(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) { in StreamingInputCallResponse() method in Messages.StreamingInputCallResponse
5732 private StreamingInputCallResponse() { in StreamingInputCallResponse() method in Messages.StreamingInputCallResponse
5741 private StreamingInputCallResponse( in StreamingInputCallResponse() method in Messages.StreamingInputCallResponse
5793 …esting.integration.Messages.StreamingInputCallResponse.class, io.grpc.testing.integration.Messages… in internalGetFieldAccessorTable()
5846 if (!(obj instanceof io.grpc.testing.integration.Messages.StreamingInputCallResponse)) { in equals()
5849 …sting.integration.Messages.StreamingInputCallResponse other = (io.grpc.testing.integration.Message… in equals()
5872 public static io.grpc.testing.integration.Messages.StreamingInputCallResponse parseFrom( in parseFrom()
5877 public static io.grpc.testing.integration.Messages.StreamingInputCallResponse parseFrom( in parseFrom()
5883 public static io.grpc.testing.integration.Messages.StreamingInputCallResponse parseFrom( in parseFrom()
[all …]
/external/grpc-grpc/test/cpp/interop/
Dinterop_server.cc63 using grpc::testing::StreamingInputCallResponse;
236 StreamingInputCallResponse* response) { in StreamingInputCall()
Dinterop_client.cc395 StreamingInputCallResponse response; in DoRequestStreaming()
464 StreamingInputCallResponse probe_res; in DoClientCompressedStreaming()
491 StreamingInputCallResponse response; in DoClientCompressedStreaming()
724 StreamingInputCallResponse response; in DoCancelAfterBegin()
/external/grpc-grpc/src/python/grpcio_tests/tests/protoc_plugin/protos/service/
Dtest_service.proto35 returns (StreamingInputCallResponse);
/external/grpc-grpc/src/ruby/pb/test/
Dserver.rb190 StreamingInputCallResponse.new(aggregated_payload_size: sum)
/external/grpc-grpc/src/objective-c/tests/RemoteTestClient/
Dtest.proto43 returns (StreamingInputCallResponse);
/external/grpc-grpc/src/objective-c/examples/RemoteTestClient/
Dtest.proto43 returns (StreamingInputCallResponse);

12