HomeSort by relevance Sort by last modified time
    Searched refs:StreamingOutputCallRequest (Results 1 - 25 of 28) sorted by null

1 2

  /external/grpc-grpc/src/ruby/pb/src/proto/grpc/testing/
test_services_pb.rb 48 rpc :StreamingOutputCall, StreamingOutputCallRequest, stream(StreamingOutputCallResponse)
55 rpc :FullDuplexCall, stream(StreamingOutputCallRequest), stream(StreamingOutputCallResponse)
60 rpc :HalfDuplexCall, stream(StreamingOutputCallRequest), stream(StreamingOutputCallResponse)
messages_pb.rb 45 add_message "grpc.testing.StreamingOutputCallRequest" do
76 StreamingOutputCallRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("grpc.testing.StreamingOutputCallRequest").msgclass
  /external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/
AbstractInteropTest.java 95 import io.grpc.testing.integration.Messages.StreamingOutputCallRequest;
502 final StreamingOutputCallRequest request = StreamingOutputCallRequest.newBuilder()
638 final StreamingOutputCallRequest request =
639 StreamingOutputCallRequest.newBuilder()
667 final List<StreamingOutputCallRequest> requests = Arrays.asList(
668 StreamingOutputCallRequest.newBuilder()
674 StreamingOutputCallRequest.newBuilder()
680 StreamingOutputCallRequest.newBuilder()
686 StreamingOutputCallRequest.newBuilder(
    [all...]
TestServiceImpl.java 38 import io.grpc.testing.integration.Messages.StreamingOutputCallRequest;
135 public void streamingOutputCall(StreamingOutputCallRequest request,
175 public StreamObserver<Messages.StreamingOutputCallRequest> fullDuplexCall(
178 return new StreamObserver<StreamingOutputCallRequest>() {
180 public void onNext(StreamingOutputCallRequest request) {
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/
TestServiceGrpc.java 130 private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest,
135 requestType = io.grpc.testing.integration.Messages.StreamingOutputCallRequest.class,
138 public static io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest,
140 io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest, io.grpc.testing.integration.Messages.StreamingOutputCallResponse> getStreamingOutputCallMethod;
145 io.grpc.MethodDescriptor.<io.grpc.testing.integration.Messages.StreamingOutputCallRequest, io.grpc.testing.integration.Messages.StreamingOutputCallResponse>newBuilder()
151 io.grpc.testing.integration.Messages.StreamingOutputCallRequest.getDefaultInstance()))
194 private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest,
199 requestType = io.grpc.testing.integration.Messages.StreamingOutputCallRequest.class,
202 public static io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest,
204 io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest, io.grpc.testing.integration.Messages.StreamingOutputCallResponse> getFullDuplexCallMethod
    [all...]
  /external/grpc-grpc/src/php/tests/qps/generated_code/Grpc/Testing/
StreamingOutputCallRequest.php 14 * Generated from protobuf message <code>grpc.testing.StreamingOutputCallRequest</code>
16 class StreamingOutputCallRequest extends \Google\Protobuf\Internal\Message
TestServiceClient.php 86 * @param \Grpc\Testing\StreamingOutputCallRequest $argument input argument
90 public function StreamingOutputCall(\Grpc\Testing\StreamingOutputCallRequest $argument,
  /external/grpc-grpc/test/cpp/interop/
interop_client.cc 425 StreamingOutputCallRequest request;
530 StreamingOutputCallRequest request;
589 StreamingOutputCallRequest request;
632 std::unique_ptr<ClientReaderWriter<StreamingOutputCallRequest,
636 StreamingOutputCallRequest request;
679 std::unique_ptr<ClientReaderWriter<StreamingOutputCallRequest,
683 StreamingOutputCallRequest request;
746 std::unique_ptr<ClientReaderWriter<StreamingOutputCallRequest,
750 StreamingOutputCallRequest request;
783 std::unique_ptr<ClientReaderWriter<StreamingOutputCallRequest,
    [all...]
interop_server.cc 64 using grpc::testing::StreamingOutputCallRequest;
194 ServerContext* context, const StreamingOutputCallRequest* request,
256 StreamingOutputCallRequest>* stream) {
258 StreamingOutputCallRequest request;
292 StreamingOutputCallRequest>* stream) {
293 std::vector<StreamingOutputCallRequest> requests;
294 StreamingOutputCallRequest request;
  /external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
ConcurrencyTest.java 31 import io.grpc.testing.integration.Messages.StreamingOutputCallRequest;
113 StreamingOutputCallRequest.Builder requestBuilder = StreamingOutputCallRequest.newBuilder()
120 StreamingOutputCallRequest request = requestBuilder.build();
Http2OkHttpTest.java 117 Messages.StreamingOutputCallRequest.Builder requestBuilder =
118 Messages.StreamingOutputCallRequest.newBuilder()
125 StreamObserver<Messages.StreamingOutputCallRequest> requestStream =
127 Messages.StreamingOutputCallRequest request = requestBuilder.build();
NettyFlowControlTest.java 33 import io.grpc.testing.integration.Messages.StreamingOutputCallRequest;
137 StreamingOutputCallRequest.Builder builder = StreamingOutputCallRequest.newBuilder()
143 StreamingOutputCallRequest request = builder.build();
  /external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/
TestServiceImpl.cs 49 public override async Task StreamingOutputCall(StreamingOutputCallRequest request, IServerStreamWriter<StreamingOutputCallResponse> responseStream, ServerCallContext context)
74 public override async Task FullDuplexCall(IAsyncStreamReader<StreamingOutputCallRequest> requestStream, IServerStreamWriter<StreamingOutputCallResponse> responseStream, ServerCallContext context)
89 public override Task HalfDuplexCall(IAsyncStreamReader<StreamingOutputCallRequest> requestStream, IServerStreamWriter<StreamingOutputCallResponse> responseStream, ServerCallContext context)
GeneratedClientTest.cs 51 Assert.Throws(typeof(NotImplementedException), () => unimplementedClient.StreamingOutputCall(new StreamingOutputCallRequest()));
InteropClient.cs 246 var request = new StreamingOutputCallRequest
265 await call.RequestStream.WriteAsync(new StreamingOutputCallRequest
274 await call.RequestStream.WriteAsync(new StreamingOutputCallRequest
283 await call.RequestStream.WriteAsync(new StreamingOutputCallRequest
292 await call.RequestStream.WriteAsync(new StreamingOutputCallRequest
424 await call.RequestStream.WriteAsync(new StreamingOutputCallRequest
458 await call.RequestStream.WriteAsync(new StreamingOutputCallRequest { Payload = CreateZerosPayload(27182) });
506 var request = new StreamingOutputCallRequest
548 var request = new StreamingOutputCallRequest { ResponseStatus = echoStatus };
TestGrpc.cs 40 static readonly grpc::Marshaller<global::Grpc.Testing.StreamingOutputCallRequest> __Marshaller_grpc_testing_StreamingOutputCallRequest = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::Grpc.Testing.StreamingOutputCallRequest.Parser.ParseFrom);
66 static readonly grpc::Method<global::Grpc.Testing.StreamingOutputCallRequest, global::Grpc.Testing.StreamingOutputCallResponse> __Method_StreamingOutputCall = new grpc::Method<global::Grpc.Testing.StreamingOutputCallRequest, global::Grpc.Testing.StreamingOutputCallResponse>(
80 static readonly grpc::Method<global::Grpc.Testing.StreamingOutputCallRequest, global::Grpc.Testing.StreamingOutputCallResponse> __Method_FullDuplexCall = new grpc::Method<global::Grpc.Testing.StreamingOutputCallRequest, global::Grpc.Testing.StreamingOutputCallResponse>(
87 static readonly grpc::Method<global::Grpc.Testing.StreamingOutputCallRequest, global::Grpc.Testing.StreamingOutputCallResponse> __Method_HalfDuplexCall = new grpc::Method<global::Grpc.Testing.StreamingOutputCallRequest, global::Grpc.Testing.StreamingOutputCallResponse>(
153 public virtual global::System.Threading.Tasks.Task StreamingOutputCall(global::Grpc.Testing.StreamingOutputCallRequest request, grpc::IServerStreamWriter<global::Grpc.Testing.StreamingOutputCallResponse> responseStream, grpc::ServerCallContext context)
179 public virtual global::System.Threading.Tasks.Task FullDuplexCall(grpc::IAsyncStreamReader<global::Grpc.Testing.StreamingOutputCallRequest> requestStream, grpc::IServerStreamWriter<global::Grpc.Testing.StreamingOutputCallResponse> respon (…)
    [all...]
GeneratedServiceBaseTest.cs 79 var call = client.StreamingOutputCall(new StreamingOutputCallRequest());
MetadataCredentialsTest.cs 112 var call = client.StreamingOutputCall(new StreamingOutputCallRequest { });
134 var call = client.StreamingOutputCall(new StreamingOutputCallRequest{ },
179 public override async Task StreamingOutputCall(StreamingOutputCallRequest request, IServerStreamWriter<StreamingOutputCallResponse> responseStream, ServerCallContext context)
  /external/grpc-grpc/src/php/tests/interop/
interop_client.php 268 $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/
methods.py 180 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/python/grpcio_tests/tests/protoc_plugin/
_python_plugin_test.py 201 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()
beta_python_plugin_test.py 266 request = requests_pb2.StreamingOutputCallRequest()
275 request = requests_pb2.StreamingOutputCallRequest()
278 request = requests_pb2.StreamingOutputCallRequest()
611 request = self._requests_pb2.StreamingOutputCallRequest()
614 request = self._requests_pb2.StreamingOutputCallRequest()
644 request = self._requests_pb2.StreamingOutputCallRequest()
  /external/grpc-grpc/src/ruby/qps/src/proto/grpc/testing/
messages_pb.rb 45 add_message "grpc.testing.StreamingOutputCallRequest" do
76 StreamingOutputCallRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("grpc.testing.StreamingOutputCallRequest").msgclass
  /external/grpc-grpc/src/ruby/pb/test/
client.rb 191 req_cls, p_cls = StreamingOutputCallRequest, ResponseParameters # short
225 req_cls = StreamingOutputCallRequest
433 req = StreamingOutputCallRequest.new(response_type: :COMPRESSABLE,
555 req_cls, p_cls = StreamingOutputCallRequest, ResponseParameters
620 req_cls, p_cls = StreamingOutputCallRequest, ResponseParameters
  /external/grpc-grpc-java/benchmarks/src/generated/main/java/io/grpc/benchmarks/proto/
Messages.java     [all...]

Completed in 1039 milliseconds

1 2