Lines Matching full:io
1 package io.grpc.testing.compiler.nano;
3 import static io.grpc.MethodDescriptor.generateFullMethodName;
4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
5 import static io.grpc.stub.ClientCalls.asyncClientStreamingCall;
6 import static io.grpc.stub.ClientCalls.asyncServerStreamingCall;
7 import static io.grpc.stub.ClientCalls.asyncUnaryCall;
8 import static io.grpc.stub.ClientCalls.blockingServerStreamingCall;
9 import static io.grpc.stub.ClientCalls.blockingUnaryCall;
10 import static io.grpc.stub.ClientCalls.futureUnaryCall;
11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
12 import static io.grpc.stub.ServerCalls.asyncClientStreamingCall;
13 import static io.grpc.stub.ServerCalls.asyncServerStreamingCall;
14 import static io.grpc.stub.ServerCalls.asyncUnaryCall;
15 import static io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall;
16 import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
18 import java.io.IOException;
37 private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.SimpleRequest,
38 io.grpc.testing.compiler.nano.Test.SimpleResponse> getUnaryCallMethod;
40 public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.SimpleRequest,
41 io.grpc.testing.compiler.nano.Test.SimpleResponse> getUnaryCallMethod() {
42 …io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.SimpleRequest, io.grpc.testing.compile…
47 …io.grpc.MethodDescriptor.<io.grpc.testing.compiler.nano.Test.SimpleRequest, io.grpc.testing.compil…
48 .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
52 ….setRequestMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.SimpleRe…
53 … new NanoFactory<io.grpc.testing.compiler.nano.Test.SimpleRequest>(ARG_IN_METHOD_UNARY_CALL)))
54 ….setResponseMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.SimpleR…
55 … new NanoFactory<io.grpc.testing.compiler.nano.Test.SimpleResponse>(ARG_OUT_METHOD_UNARY_CALL)))
65 …private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingOutpu…
66 io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod;
68 …public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingOutputCallReque…
69 … io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod() {
70 …io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest, io.grpc.te…
75 …io.grpc.MethodDescriptor.<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest, io.grpc.t…
76 .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
80 ….setRequestMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.Streamin…
81 …new NanoFactory<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest>(ARG_IN_METHOD_STREA…
82 ….setResponseMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.Streami…
83 …new NanoFactory<io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse>(ARG_OUT_METHOD_STR…
93 …private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingInput…
94 io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse> getStreamingInputCallMethod;
96 …public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingInputCallReques…
97 io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse> getStreamingInputCallMethod() {
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…
104 .setType(io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING)
108 ….setRequestMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.Streamin…
109 …new NanoFactory<io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest>(ARG_IN_METHOD_STREAM…
110 ….setResponseMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.Streami…
111 …new NanoFactory<io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse>(ARG_OUT_METHOD_STRE…
121 …private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingOutpu…
122 io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> getFullBidiCallMethod;
124 …public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingOutputCallReque…
125 io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> getFullBidiCallMethod() {
126 …io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest, io.grpc.te…
131 …io.grpc.MethodDescriptor.<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest, io.grpc.t…
132 .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
136 ….setRequestMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.Streamin…
137 …new NanoFactory<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest>(ARG_IN_METHOD_FULL_…
138 ….setResponseMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.Streami…
139 …new NanoFactory<io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse>(ARG_OUT_METHOD_FUL…
149 …private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingOutpu…
150 io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> getHalfBidiCallMethod;
152 …public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingOutputCallReque…
153 io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> getHalfBidiCallMethod() {
154 …io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest, io.grpc.te…
159 …io.grpc.MethodDescriptor.<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest, io.grpc.t…
160 .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
164 ….setRequestMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.Streamin…
165 …new NanoFactory<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest>(ARG_IN_METHOD_HALF_…
166 ….setResponseMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.Streami…
167 …new NanoFactory<io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse>(ARG_OUT_METHOD_HAL…
177 …private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingInput…
178 io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse> getImportMethod;
180 …public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingInputCallReques…
181 io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse> getImportMethod() {
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…
188 .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
192 ….setRequestMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.Streamin…
193 …new NanoFactory<io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest>(ARG_IN_METHOD_IMPORT…
194 ….setResponseMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.Streami…
195 …new NanoFactory<io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse>(ARG_OUT_METHOD_IMPO…
204 implements io.grpc.protobuf.nano.MessageNanoFactory<T> {
216 o = new io.grpc.testing.compiler.nano.Test.SimpleRequest();
219 o = new io.grpc.testing.compiler.nano.Test.SimpleResponse();
222 o = new io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest();
225 o = new io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse();
228 o = new io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest();
231 o = new io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse();
234 o = new io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest();
237 o = new io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse();
240 o = new io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest();
243 o = new io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse();
246 o = new io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest();
249 o = new io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse();
263 public static TestServiceStub newStub(io.grpc.Channel channel) {
271 io.grpc.Channel channel) {
279 io.grpc.Channel channel) {
288 public static abstract class TestServiceImplBase implements io.grpc.BindableService {
296 public void unaryCall(io.grpc.testing.compiler.nano.Test.SimpleRequest request,
297 … io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.SimpleResponse> responseObserver) {
307 …public void streamingOutputCall(io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest requ…
308 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> respon…
318 …public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest> s…
319 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse> respons…
330 …public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest> …
331 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> respon…
343 …public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest> …
344 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> respon…
354 …public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest> i…
355 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse> respons…
359 @java.lang.Override public final io.grpc.ServerServiceDefinition bindService() {
360 return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
365 io.grpc.testing.compiler.nano.Test.SimpleRequest,
366 io.grpc.testing.compiler.nano.Test.SimpleResponse>(
372 io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest,
373 io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse>(
379 io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest,
380 io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse>(
386 io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest,
387 io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse>(
393 io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest,
394 io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse>(
400 io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest,
401 io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse>(
412 public static final class TestServiceStub extends io.grpc.stub.AbstractStub<TestServiceStub> {
413 private TestServiceStub(io.grpc.Channel channel) {
417 private TestServiceStub(io.grpc.Channel channel,
418 io.grpc.CallOptions callOptions) {
423 protected TestServiceStub build(io.grpc.Channel channel,
424 io.grpc.CallOptions callOptions) {
434 public void unaryCall(io.grpc.testing.compiler.nano.Test.SimpleRequest request,
435 … io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.SimpleResponse> responseObserver) {
446 …public void streamingOutputCall(io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest requ…
447 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> respon…
458 …public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest> s…
459 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse> respons…
471 …public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest> …
472 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> respon…
485 …public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest> …
486 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> respon…
497 …public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest> i…
498 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse> respons…
509 …public static final class TestServiceBlockingStub extends io.grpc.stub.AbstractStub<TestServiceBlo…
510 private TestServiceBlockingStub(io.grpc.Channel channel) {
514 private TestServiceBlockingStub(io.grpc.Channel channel,
515 io.grpc.CallOptions callOptions) {
520 protected TestServiceBlockingStub build(io.grpc.Channel channel,
521 io.grpc.CallOptions callOptions) {
531 …public io.grpc.testing.compiler.nano.Test.SimpleResponse unaryCall(io.grpc.testing.compiler.nano.T…
542 …public java.util.Iterator<io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> streamin…
543 io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest request) {
554 …public static final class TestServiceFutureStub extends io.grpc.stub.AbstractStub<TestServiceFutur…
555 private TestServiceFutureStub(io.grpc.Channel channel) {
559 private TestServiceFutureStub(io.grpc.Channel channel,
560 io.grpc.CallOptions callOptions) {
565 protected TestServiceFutureStub build(io.grpc.Channel channel,
566 io.grpc.CallOptions callOptions) {
576 …public com.google.common.util.concurrent.ListenableFuture<io.grpc.testing.compiler.nano.Test.Simpl…
577 io.grpc.testing.compiler.nano.Test.SimpleRequest request) {
591 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
592 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
593 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
594 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
605 public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) {
608 serviceImpl.unaryCall((io.grpc.testing.compiler.nano.Test.SimpleRequest) request,
609 …(io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.SimpleResponse>) responseObserver);
612 …serviceImpl.streamingOutputCall((io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest) re…
613 …(io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse>) resp…
622 public io.grpc.stub.StreamObserver<Req> invoke(
623 io.grpc.stub.StreamObserver<Resp> responseObserver) {
626 return (io.grpc.stub.StreamObserver<Req>) serviceImpl.streamingInputCall(
627 …(io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse>) respo…
629 return (io.grpc.stub.StreamObserver<Req>) serviceImpl.fullBidiCall(
630 …(io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse>) resp…
632 return (io.grpc.stub.StreamObserver<Req>) serviceImpl.halfBidiCall(
633 …(io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse>) resp…
635 return (io.grpc.stub.StreamObserver<Req>) serviceImpl.import_(
636 …(io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse>) respo…
643 private static volatile io.grpc.ServiceDescriptor serviceDescriptor;
645 public static io.grpc.ServiceDescriptor getServiceDescriptor() {
646 io.grpc.ServiceDescriptor result = serviceDescriptor;
651 serviceDescriptor = result = io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)