Lines Matching full:io
1 package io.grpc.testing.compiler;
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;
33 private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest,
34 io.grpc.testing.compiler.Test.SimpleResponse> getUnaryCallMethod;
36 @io.grpc.stub.annotations.RpcMethod(
38 requestType = io.grpc.testing.compiler.Test.SimpleRequest.class,
39 responseType = io.grpc.testing.compiler.Test.SimpleResponse.class,
40 methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
41 public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest,
42 io.grpc.testing.compiler.Test.SimpleResponse> getUnaryCallMethod() {
43 …io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Tes…
48 …io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Te…
49 .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
53 .setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
54 io.grpc.testing.compiler.Test.SimpleRequest.getDefaultInstance()))
55 .setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
56 io.grpc.testing.compiler.Test.SimpleResponse.getDefaultInstance()))
64 …private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCall…
65 io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod;
67 @io.grpc.stub.annotations.RpcMethod(
69 requestType = io.grpc.testing.compiler.Test.StreamingOutputCallRequest.class,
70 responseType = io.grpc.testing.compiler.Test.StreamingOutputCallResponse.class,
71 methodType = io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
72 public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
73 io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod() {
74 …io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing…
79 …io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testin…
80 .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
84 .setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
85 io.grpc.testing.compiler.Test.StreamingOutputCallRequest.getDefaultInstance()))
86 .setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
87 io.grpc.testing.compiler.Test.StreamingOutputCallResponse.getDefaultInstance()))
95 …private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallR…
96 io.grpc.testing.compiler.Test.StreamingInputCallResponse> getStreamingInputCallMethod;
98 @io.grpc.stub.annotations.RpcMethod(
100 requestType = io.grpc.testing.compiler.Test.StreamingInputCallRequest.class,
101 responseType = io.grpc.testing.compiler.Test.StreamingInputCallResponse.class,
102 methodType = io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING)
103 public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
104 io.grpc.testing.compiler.Test.StreamingInputCallResponse> getStreamingInputCallMethod() {
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…
111 .setType(io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING)
115 .setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
116 io.grpc.testing.compiler.Test.StreamingInputCallRequest.getDefaultInstance()))
117 .setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
118 io.grpc.testing.compiler.Test.StreamingInputCallResponse.getDefaultInstance()))
126 …private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCall…
127 io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getFullBidiCallMethod;
129 @io.grpc.stub.annotations.RpcMethod(
131 requestType = io.grpc.testing.compiler.Test.StreamingOutputCallRequest.class,
132 responseType = io.grpc.testing.compiler.Test.StreamingOutputCallResponse.class,
133 methodType = io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
134 public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
135 io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getFullBidiCallMethod() {
136 …io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing…
141 …io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testin…
142 .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
146 .setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
147 io.grpc.testing.compiler.Test.StreamingOutputCallRequest.getDefaultInstance()))
148 .setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
149 io.grpc.testing.compiler.Test.StreamingOutputCallResponse.getDefaultInstance()))
157 …private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCall…
158 io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getHalfBidiCallMethod;
160 @io.grpc.stub.annotations.RpcMethod(
162 requestType = io.grpc.testing.compiler.Test.StreamingOutputCallRequest.class,
163 responseType = io.grpc.testing.compiler.Test.StreamingOutputCallResponse.class,
164 methodType = io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
165 public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
166 io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getHalfBidiCallMethod() {
167 …io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing…
172 …io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testin…
173 .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
177 .setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
178 io.grpc.testing.compiler.Test.StreamingOutputCallRequest.getDefaultInstance()))
179 .setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
180 io.grpc.testing.compiler.Test.StreamingOutputCallResponse.getDefaultInstance()))
188 …private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallR…
189 io.grpc.testing.compiler.Test.StreamingInputCallResponse> getImportMethod;
191 @io.grpc.stub.annotations.RpcMethod(
193 requestType = io.grpc.testing.compiler.Test.StreamingInputCallRequest.class,
194 responseType = io.grpc.testing.compiler.Test.StreamingInputCallResponse.class,
195 methodType = io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
196 public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
197 io.grpc.testing.compiler.Test.StreamingInputCallResponse> getImportMethod() {
198 …io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest, io.grpc.testing.…
203 …io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingInputCallRequest, io.grpc.testing…
204 .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
208 .setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
209 io.grpc.testing.compiler.Test.StreamingInputCallRequest.getDefaultInstance()))
210 .setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
211 io.grpc.testing.compiler.Test.StreamingInputCallResponse.getDefaultInstance()))
222 public static TestServiceStub newStub(io.grpc.Channel channel) {
230 io.grpc.Channel channel) {
238 io.grpc.Channel channel) {
247 public static abstract class TestServiceImplBase implements io.grpc.BindableService {
255 public void unaryCall(io.grpc.testing.compiler.Test.SimpleRequest request,
256 … io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse> responseObserver) {
266 … public void streamingOutputCall(io.grpc.testing.compiler.Test.StreamingOutputCallRequest request,
267 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObs…
277 …public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallRequest> stream…
278 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallResponse> responseObse…
289 …public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallRequest> fullB…
290 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObs…
302 …public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallRequest> halfB…
303 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObs…
313 …public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallRequest> import…
314 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallResponse> responseObse…
318 @java.lang.Override public final io.grpc.ServerServiceDefinition bindService() {
319 return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
324 io.grpc.testing.compiler.Test.SimpleRequest,
325 io.grpc.testing.compiler.Test.SimpleResponse>(
331 io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
332 io.grpc.testing.compiler.Test.StreamingOutputCallResponse>(
338 io.grpc.testing.compiler.Test.StreamingInputCallRequest,
339 io.grpc.testing.compiler.Test.StreamingInputCallResponse>(
345 io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
346 io.grpc.testing.compiler.Test.StreamingOutputCallResponse>(
352 io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
353 io.grpc.testing.compiler.Test.StreamingOutputCallResponse>(
359 io.grpc.testing.compiler.Test.StreamingInputCallRequest,
360 io.grpc.testing.compiler.Test.StreamingInputCallResponse>(
371 public static final class TestServiceStub extends io.grpc.stub.AbstractStub<TestServiceStub> {
372 private TestServiceStub(io.grpc.Channel channel) {
376 private TestServiceStub(io.grpc.Channel channel,
377 io.grpc.CallOptions callOptions) {
382 protected TestServiceStub build(io.grpc.Channel channel,
383 io.grpc.CallOptions callOptions) {
393 public void unaryCall(io.grpc.testing.compiler.Test.SimpleRequest request,
394 … io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse> responseObserver) {
405 … public void streamingOutputCall(io.grpc.testing.compiler.Test.StreamingOutputCallRequest request,
406 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObs…
417 …public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallRequest> stream…
418 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallResponse> responseObse…
430 …public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallRequest> fullB…
431 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObs…
444 …public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallRequest> halfB…
445 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObs…
456 …public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallRequest> import…
457 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallResponse> responseObse…
468 …public static final class TestServiceBlockingStub extends io.grpc.stub.AbstractStub<TestServiceBlo…
469 private TestServiceBlockingStub(io.grpc.Channel channel) {
473 private TestServiceBlockingStub(io.grpc.Channel channel,
474 io.grpc.CallOptions callOptions) {
479 protected TestServiceBlockingStub build(io.grpc.Channel channel,
480 io.grpc.CallOptions callOptions) {
490 …public io.grpc.testing.compiler.Test.SimpleResponse unaryCall(io.grpc.testing.compiler.Test.Simple…
501 …public java.util.Iterator<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> streamingOutp…
502 io.grpc.testing.compiler.Test.StreamingOutputCallRequest request) {
513 …public static final class TestServiceFutureStub extends io.grpc.stub.AbstractStub<TestServiceFutur…
514 private TestServiceFutureStub(io.grpc.Channel channel) {
518 private TestServiceFutureStub(io.grpc.Channel channel,
519 io.grpc.CallOptions callOptions) {
524 protected TestServiceFutureStub build(io.grpc.Channel channel,
525 io.grpc.CallOptions callOptions) {
535 …public com.google.common.util.concurrent.ListenableFuture<io.grpc.testing.compiler.Test.SimpleResp…
536 io.grpc.testing.compiler.Test.SimpleRequest request) {
550 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
551 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
552 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
553 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
564 public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) {
567 serviceImpl.unaryCall((io.grpc.testing.compiler.Test.SimpleRequest) request,
568 … (io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse>) responseObserver);
571 …serviceImpl.streamingOutputCall((io.grpc.testing.compiler.Test.StreamingOutputCallRequest) request,
572 …(io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse>) responseO…
581 public io.grpc.stub.StreamObserver<Req> invoke(
582 io.grpc.stub.StreamObserver<Resp> responseObserver) {
585 return (io.grpc.stub.StreamObserver<Req>) serviceImpl.streamingInputCall(
586 …(io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallResponse>) responseOb…
588 return (io.grpc.stub.StreamObserver<Req>) serviceImpl.fullBidiCall(
589 …(io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse>) responseO…
591 return (io.grpc.stub.StreamObserver<Req>) serviceImpl.halfBidiCall(
592 …(io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse>) responseO…
594 return (io.grpc.stub.StreamObserver<Req>) serviceImpl.import_(
595 …(io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallResponse>) responseOb…
602 private static volatile io.grpc.ServiceDescriptor serviceDescriptor;
604 public static io.grpc.ServiceDescriptor getServiceDescriptor() {
605 io.grpc.ServiceDescriptor result = serviceDescriptor;
610 serviceDescriptor = result = io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)