Home
last modified time | relevance | path

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

12

/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
DMoreInProcessTest.java30 import io.grpc.testing.integration.Messages.StreamingInputCallRequest;
82 public StreamObserver<StreamingInputCallRequest> streamingInputCall( in asyncClientStreaming_serverResponsePriorToRequest()
87 return new StreamObserver<StreamingInputCallRequest>() { in asyncClientStreaming_serverResponsePriorToRequest()
89 public void onNext(StreamingInputCallRequest value) { in asyncClientStreaming_serverResponsePriorToRequest()
141 public StreamObserver<StreamingInputCallRequest> streamingInputCall( in asyncClientStreaming_serverErrorPriorToRequest()
146 return new StreamObserver<StreamingInputCallRequest>() { in asyncClientStreaming_serverErrorPriorToRequest()
148 public void onNext(StreamingInputCallRequest value) { in asyncClientStreaming_serverErrorPriorToRequest()
199 public StreamObserver<StreamingInputCallRequest> streamingInputCall( in asyncClientStreaming_erroneousServiceImpl()
201 StreamObserver<StreamingInputCallRequest> requestObserver = in asyncClientStreaming_erroneousServiceImpl()
202 new StreamObserver<StreamingInputCallRequest>() { in asyncClientStreaming_erroneousServiceImpl()
[all …]
/external/grpc-grpc-java/compiler/src/testNano/golden/
DTestService.java.txt93 …tic volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest,
96 …ublic static io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest,
98 …io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest, io.grpc.tes…
103 …io.grpc.MethodDescriptor.<io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest, io.grpc.te…
108 …rpc.protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest>marshall…
109 …new NanoFactory<io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest>(ARG_IN_METHOD_STREAM…
177 …tic volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest,
180 …ublic static io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest,
182 …io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest, io.grpc.tes…
187 …io.grpc.MethodDescriptor.<io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest, io.grpc.te…
[all …]
/external/grpc-grpc-java/compiler/src/testLite/golden/
DTestService.java.txt95 …e static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
100 requestType = io.grpc.testing.compiler.Test.StreamingInputCallRequest.class,
103 public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
105 …io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest, io.grpc.testing.…
110 …io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingInputCallRequest, io.grpc.testing…
116 io.grpc.testing.compiler.Test.StreamingInputCallRequest.getDefaultInstance()))
188 …e static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
193 requestType = io.grpc.testing.compiler.Test.StreamingInputCallRequest.class,
196 public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
198 …io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest, io.grpc.testing.…
[all …]
/external/grpc-grpc-java/compiler/src/test/golden/
DTestService.java.txt97 …e static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
102 requestType = io.grpc.testing.compiler.Test.StreamingInputCallRequest.class,
105 public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
107 …io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest, io.grpc.testing.…
112 …io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingInputCallRequest, io.grpc.testing…
118 io.grpc.testing.compiler.Test.StreamingInputCallRequest.getDefaultInstance()))
193 …e static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
198 requestType = io.grpc.testing.compiler.Test.StreamingInputCallRequest.class,
201 public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
203 …io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest, io.grpc.testing.…
[all …]
/external/grpc-grpc-java/compiler/src/test/proto/grpc/testing/compiler/
Dtest.proto29 message StreamingInputCallRequest { message
54 rpc StreamingInputCall(stream StreamingInputCallRequest)
72 rpc Import(stream StreamingInputCallRequest) returns (stream StreamingInputCallResponse);
/external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/
DMessages.cs66 …lrTypeInfo(typeof(global::Grpc.Testing.StreamingInputCallRequest), global::Grpc.Testing.StreamingI… in MessagesReflection()
1143 public sealed partial class StreamingInputCallRequest : pb::IMessage<StreamingInputCallRequest> { class
1144 …::MessageParser<StreamingInputCallRequest> _parser = new pb::MessageParser<StreamingInputCallReque…
1147 public static pb::MessageParser<StreamingInputCallRequest> Parser { get { return _parser; } }
1160 public StreamingInputCallRequest() { in StreamingInputCallRequest() method in Grpc.Testing.StreamingInputCallRequest
1167 public StreamingInputCallRequest(StreamingInputCallRequest other) : this() { in StreamingInputCallRequest() method in Grpc.Testing.StreamingInputCallRequest
1174 public StreamingInputCallRequest Clone() { in Clone()
1175 return new StreamingInputCallRequest(this); in Clone()
1211 return Equals(other as StreamingInputCallRequest); in Equals()
1215 public bool Equals(StreamingInputCallRequest other) { in Equals()
[all …]
DTestGrpc.cs42 …StreamingInputCallRequest> __Marshaller_grpc_testing_StreamingInputCallRequest = grpc::Marshallers…
73 …StreamingInputCallRequest, global::Grpc.Testing.StreamingInputCallResponse> __Method_StreamingInpu…
165 …treamingInputCall(grpc::IAsyncStreamReader<global::Grpc.Testing.StreamingInputCallRequest> request… in StreamingInputCall()
408 …public virtual grpc::AsyncClientStreamingCall<global::Grpc.Testing.StreamingInputCallRequest, glob… in StreamingInputCall()
418 …public virtual grpc::AsyncClientStreamingCall<global::Grpc.Testing.StreamingInputCallRequest, glob… in StreamingInputCall()
DInteropClient.cs228 … = new List<int> { 27182, 8, 1828, 45904 }.Select((size) => new StreamingInputCallRequest { Payloa… in RunClientStreamingAsync()
636 await probeCall.RequestStream.WriteAsync(new StreamingInputCallRequest in RunClientCompressedStreamingAsync()
655 await call.RequestStream.WriteAsync(new StreamingInputCallRequest in RunClientCompressedStreamingAsync()
665 await call.RequestStream.WriteAsync(new StreamingInputCallRequest in RunClientCompressedStreamingAsync()
DSslCredentialsTest.cs102 …reamingInputCallResponse> StreamingInputCall(IAsyncStreamReader<StreamingInputCallRequest> request… in StreamingInputCall()
DTestServiceImpl.cs61 …reamingInputCallResponse> StreamingInputCall(IAsyncStreamReader<StreamingInputCallRequest> request… in StreamingInputCall()
/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/
DTestServiceImpl.java36 import io.grpc.testing.integration.Messages.StreamingInputCallRequest;
146 public StreamObserver<Messages.StreamingInputCallRequest> streamingInputCall( in streamingInputCall()
148 return new StreamObserver<StreamingInputCallRequest>() { in streamingInputCall()
152 public void onNext(StreamingInputCallRequest message) { in streamingInputCall()
DAbstractInteropTest.java93 import io.grpc.testing.integration.Messages.StreamingInputCallRequest;
544 final List<StreamingInputCallRequest> requests = Arrays.asList( in clientStreaming()
545 StreamingInputCallRequest.newBuilder() in clientStreaming()
549 StreamingInputCallRequest.newBuilder() in clientStreaming()
553 StreamingInputCallRequest.newBuilder() in clientStreaming()
557 StreamingInputCallRequest.newBuilder() in clientStreaming()
566 StreamObserver<StreamingInputCallRequest> requestObserver = in clientStreaming()
568 for (StreamingInputCallRequest request : requests) { in clientStreaming()
588 final StreamingInputCallRequest expectCompressedRequest = in clientCompressedStreaming()
589 StreamingInputCallRequest.newBuilder() in clientCompressedStreaming()
[all …]
/external/grpc-grpc/test/cpp/interop/
Dinterop_client.cc394 StreamingInputCallRequest request; in DoRequestStreaming()
397 std::unique_ptr<ClientWriter<StreamingInputCallRequest>> stream( in DoRequestStreaming()
463 StreamingInputCallRequest probe_req; in DoClientCompressedStreaming()
472 std::unique_ptr<ClientWriter<StreamingInputCallRequest>> probe_stream( in DoClientCompressedStreaming()
490 StreamingInputCallRequest request; in DoClientCompressedStreaming()
494 std::unique_ptr<ClientWriter<StreamingInputCallRequest>> stream( in DoClientCompressedStreaming()
723 StreamingInputCallRequest request; in DoCancelAfterBegin()
726 std::unique_ptr<ClientWriter<StreamingInputCallRequest>> stream( in DoCancelAfterBegin()
Dinterop_server.cc62 using grpc::testing::StreamingInputCallRequest;
235 ServerReader<StreamingInputCallRequest>* reader, in StreamingInputCall()
237 StreamingInputCallRequest request; in StreamingInputCall()
/external/grpc-grpc-java/interop-testing/src/generated/main/grpc/io/grpc/testing/integration/
DTestServiceGrpc.java162 …c volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingInputCallRequest,
167 requestType = io.grpc.testing.integration.Messages.StreamingInputCallRequest.class,
170 …lic static io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingInputCallRequest,
172 …io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingInputCallRequest, io.grpc.t… in getStreamingInputCallMethod()
177 …io.grpc.MethodDescriptor.<io.grpc.testing.integration.Messages.StreamingInputCallRequest, io.grpc.… in getStreamingInputCallMethod()
183 … io.grpc.testing.integration.Messages.StreamingInputCallRequest.getDefaultInstance())) in getStreamingInputCallMethod()
370 …o.grpc.stub.StreamObserver<io.grpc.testing.integration.Messages.StreamingInputCallRequest> streami… in streamingInputCall()
445 io.grpc.testing.integration.Messages.StreamingInputCallRequest, in bindService()
548 …o.grpc.stub.StreamObserver<io.grpc.testing.integration.Messages.StreamingInputCallRequest> streami… in streamingInputCall()
/external/grpc-grpc/src/php/tests/qps/generated_code/Grpc/Testing/
DStreamingInputCallRequest.php16 class StreamingInputCallRequest 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.rb73 …StreamingInputCallRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("grpc.testing.S… constant
/external/grpc-grpc/src/ruby/pb/test/
Dclient.rb378 StreamingInputCallRequest.new(payload: req)
388 first_request = StreamingInputCallRequest.new(
402 second_request = StreamingInputCallRequest.new(
480 StreamingInputCallRequest.new(payload: req)
/external/grpc-grpc/src/ruby/qps/src/proto/grpc/testing/
Dmessages_pb.rb73 …StreamingInputCallRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("grpc.testing.S… constant
/external/grpc-grpc-java/interop-testing/src/generated/main/java/io/grpc/testing/integration/
DMessages.java4824 public static final class StreamingInputCallRequest extends class in Messages
4830 private StreamingInputCallRequest(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) { in StreamingInputCallRequest() method in Messages.StreamingInputCallRequest
4833 private StreamingInputCallRequest() { in StreamingInputCallRequest() method in Messages.StreamingInputCallRequest
4841 private StreamingInputCallRequest( in StreamingInputCallRequest() method in Messages.StreamingInputCallRequest
4914 …testing.integration.Messages.StreamingInputCallRequest.class, io.grpc.testing.integration.Messages… in internalGetFieldAccessorTable()
5036 if (!(obj instanceof io.grpc.testing.integration.Messages.StreamingInputCallRequest)) { in equals()
5039 …esting.integration.Messages.StreamingInputCallRequest other = (io.grpc.testing.integration.Message… in equals()
5076 public static io.grpc.testing.integration.Messages.StreamingInputCallRequest parseFrom( in parseFrom()
5081 public static io.grpc.testing.integration.Messages.StreamingInputCallRequest parseFrom( in parseFrom()
5087 public static io.grpc.testing.integration.Messages.StreamingInputCallRequest parseFrom( in parseFrom()
[all …]
/external/grpc-grpc-java/benchmarks/src/generated/main/java/io/grpc/benchmarks/proto/
DMessages.java4749 public static final class StreamingInputCallRequest extends class in Messages
4755 private StreamingInputCallRequest(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) { in StreamingInputCallRequest() method in Messages.StreamingInputCallRequest
4758 private StreamingInputCallRequest() { in StreamingInputCallRequest() method in Messages.StreamingInputCallRequest
4766 private StreamingInputCallRequest( in StreamingInputCallRequest() method in Messages.StreamingInputCallRequest
4839 …rpc.benchmarks.proto.Messages.StreamingInputCallRequest.class, io.grpc.benchmarks.proto.Messages.S… in internalGetFieldAccessorTable()
4961 if (!(obj instanceof io.grpc.benchmarks.proto.Messages.StreamingInputCallRequest)) { in equals()
4964 …pc.benchmarks.proto.Messages.StreamingInputCallRequest other = (io.grpc.benchmarks.proto.Messages.… in equals()
5001 public static io.grpc.benchmarks.proto.Messages.StreamingInputCallRequest parseFrom( in parseFrom()
5006 public static io.grpc.benchmarks.proto.Messages.StreamingInputCallRequest parseFrom( in parseFrom()
5012 public static io.grpc.benchmarks.proto.Messages.StreamingInputCallRequest parseFrom( in parseFrom()
[all …]
/external/grpc-grpc/src/python/grpcio_tests/tests/protoc_plugin/protos/requests/r/
Dtest_requests.proto34 message StreamingInputCallRequest { message
/external/grpc-grpc/src/python/grpcio_tests/tests/protoc_plugin/protos/service/
Dtest_service.proto34 rpc StreamingInputCall(stream StreamingInputCallRequest)
/external/grpc-grpc/src/objective-c/tests/RemoteTestClient/
Dtest.proto42 rpc StreamingInputCall(stream StreamingInputCallRequest)

12