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.ProtoUtils.marshaller(
54 io.grpc.testing.compiler.Test.SimpleRequest.getDefaultInstance()))
55 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
56 io.grpc.testing.compiler.Test.SimpleResponse.getDefaultInstance()))
65 …private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCall…
66 io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod;
68 @io.grpc.stub.annotations.RpcMethod(
70 requestType = io.grpc.testing.compiler.Test.StreamingOutputCallRequest.class,
71 responseType = io.grpc.testing.compiler.Test.StreamingOutputCallResponse.class,
72 methodType = io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
73 public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
74 io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod() {
75 …io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing…
80 …io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testin…
81 .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
85 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
86 io.grpc.testing.compiler.Test.StreamingOutputCallRequest.getDefaultInstance()))
87 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
88 io.grpc.testing.compiler.Test.StreamingOutputCallResponse.getDefaultInstance()))
97 …private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallR…
98 io.grpc.testing.compiler.Test.StreamingInputCallResponse> getStreamingInputCallMethod;
100 @io.grpc.stub.annotations.RpcMethod(
102 requestType = io.grpc.testing.compiler.Test.StreamingInputCallRequest.class,
103 responseType = io.grpc.testing.compiler.Test.StreamingInputCallResponse.class,
104 methodType = io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING)
105 public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
106 io.grpc.testing.compiler.Test.StreamingInputCallResponse> getStreamingInputCallMethod() {
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…
113 .setType(io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING)
117 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
118 io.grpc.testing.compiler.Test.StreamingInputCallRequest.getDefaultInstance()))
119 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
120 io.grpc.testing.compiler.Test.StreamingInputCallResponse.getDefaultInstance()))
129 …private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCall…
130 io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getFullBidiCallMethod;
132 @io.grpc.stub.annotations.RpcMethod(
134 requestType = io.grpc.testing.compiler.Test.StreamingOutputCallRequest.class,
135 responseType = io.grpc.testing.compiler.Test.StreamingOutputCallResponse.class,
136 methodType = io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
137 public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
138 io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getFullBidiCallMethod() {
139 …io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing…
144 …io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testin…
145 .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
149 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
150 io.grpc.testing.compiler.Test.StreamingOutputCallRequest.getDefaultInstance()))
151 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
152 io.grpc.testing.compiler.Test.StreamingOutputCallResponse.getDefaultInstance()))
161 …private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCall…
162 io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getHalfBidiCallMethod;
164 @io.grpc.stub.annotations.RpcMethod(
166 requestType = io.grpc.testing.compiler.Test.StreamingOutputCallRequest.class,
167 responseType = io.grpc.testing.compiler.Test.StreamingOutputCallResponse.class,
168 methodType = io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
169 public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
170 io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getHalfBidiCallMethod() {
171 …io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing…
176 …io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testin…
177 .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
181 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
182 io.grpc.testing.compiler.Test.StreamingOutputCallRequest.getDefaultInstance()))
183 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
184 io.grpc.testing.compiler.Test.StreamingOutputCallResponse.getDefaultInstance()))
193 …private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallR…
194 io.grpc.testing.compiler.Test.StreamingInputCallResponse> getImportMethod;
196 @io.grpc.stub.annotations.RpcMethod(
198 requestType = io.grpc.testing.compiler.Test.StreamingInputCallRequest.class,
199 responseType = io.grpc.testing.compiler.Test.StreamingInputCallResponse.class,
200 methodType = io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
201 public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
202 io.grpc.testing.compiler.Test.StreamingInputCallResponse> getImportMethod() {
203 …io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest, io.grpc.testing.…
208 …io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingInputCallRequest, io.grpc.testing…
209 .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
213 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
214 io.grpc.testing.compiler.Test.StreamingInputCallRequest.getDefaultInstance()))
215 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
216 io.grpc.testing.compiler.Test.StreamingInputCallResponse.getDefaultInstance()))
228 public static TestServiceStub newStub(io.grpc.Channel channel) {
236 io.grpc.Channel channel) {
244 io.grpc.Channel channel) {
253 public static abstract class TestServiceImplBase implements io.grpc.BindableService {
261 public void unaryCall(io.grpc.testing.compiler.Test.SimpleRequest request,
262 … io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse> responseObserver) {
272 … public void streamingOutputCall(io.grpc.testing.compiler.Test.StreamingOutputCallRequest request,
273 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObs…
283 …public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallRequest> stream…
284 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallResponse> responseObse…
295 …public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallRequest> fullB…
296 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObs…
308 …public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallRequest> halfB…
309 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObs…
319 …public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallRequest> import…
320 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallResponse> responseObse…
324 @java.lang.Override public final io.grpc.ServerServiceDefinition bindService() {
325 return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
330 io.grpc.testing.compiler.Test.SimpleRequest,
331 io.grpc.testing.compiler.Test.SimpleResponse>(
337 io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
338 io.grpc.testing.compiler.Test.StreamingOutputCallResponse>(
344 io.grpc.testing.compiler.Test.StreamingInputCallRequest,
345 io.grpc.testing.compiler.Test.StreamingInputCallResponse>(
351 io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
352 io.grpc.testing.compiler.Test.StreamingOutputCallResponse>(
358 io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
359 io.grpc.testing.compiler.Test.StreamingOutputCallResponse>(
365 io.grpc.testing.compiler.Test.StreamingInputCallRequest,
366 io.grpc.testing.compiler.Test.StreamingInputCallResponse>(
377 public static final class TestServiceStub extends io.grpc.stub.AbstractStub<TestServiceStub> {
378 private TestServiceStub(io.grpc.Channel channel) {
382 private TestServiceStub(io.grpc.Channel channel,
383 io.grpc.CallOptions callOptions) {
388 protected TestServiceStub build(io.grpc.Channel channel,
389 io.grpc.CallOptions callOptions) {
399 public void unaryCall(io.grpc.testing.compiler.Test.SimpleRequest request,
400 … io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse> responseObserver) {
411 … public void streamingOutputCall(io.grpc.testing.compiler.Test.StreamingOutputCallRequest request,
412 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObs…
423 …public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallRequest> stream…
424 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallResponse> responseObse…
436 …public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallRequest> fullB…
437 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObs…
450 …public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallRequest> halfB…
451 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObs…
462 …public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallRequest> import…
463 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallResponse> responseObse…
474 …public static final class TestServiceBlockingStub extends io.grpc.stub.AbstractStub<TestServiceBlo…
475 private TestServiceBlockingStub(io.grpc.Channel channel) {
479 private TestServiceBlockingStub(io.grpc.Channel channel,
480 io.grpc.CallOptions callOptions) {
485 protected TestServiceBlockingStub build(io.grpc.Channel channel,
486 io.grpc.CallOptions callOptions) {
496 …public io.grpc.testing.compiler.Test.SimpleResponse unaryCall(io.grpc.testing.compiler.Test.Simple…
507 …public java.util.Iterator<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> streamingOutp…
508 io.grpc.testing.compiler.Test.StreamingOutputCallRequest request) {
519 …public static final class TestServiceFutureStub extends io.grpc.stub.AbstractStub<TestServiceFutur…
520 private TestServiceFutureStub(io.grpc.Channel channel) {
524 private TestServiceFutureStub(io.grpc.Channel channel,
525 io.grpc.CallOptions callOptions) {
530 protected TestServiceFutureStub build(io.grpc.Channel channel,
531 io.grpc.CallOptions callOptions) {
541 …public com.google.common.util.concurrent.ListenableFuture<io.grpc.testing.compiler.Test.SimpleResp…
542 io.grpc.testing.compiler.Test.SimpleRequest request) {
556 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
557 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
558 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
559 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
570 public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) {
573 serviceImpl.unaryCall((io.grpc.testing.compiler.Test.SimpleRequest) request,
574 … (io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse>) responseObserver);
577 …serviceImpl.streamingOutputCall((io.grpc.testing.compiler.Test.StreamingOutputCallRequest) request,
578 …(io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse>) responseO…
587 public io.grpc.stub.StreamObserver<Req> invoke(
588 io.grpc.stub.StreamObserver<Resp> responseObserver) {
591 return (io.grpc.stub.StreamObserver<Req>) serviceImpl.streamingInputCall(
592 …(io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallResponse>) responseOb…
594 return (io.grpc.stub.StreamObserver<Req>) serviceImpl.fullBidiCall(
595 …(io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse>) responseO…
597 return (io.grpc.stub.StreamObserver<Req>) serviceImpl.halfBidiCall(
598 …(io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse>) responseO…
600 return (io.grpc.stub.StreamObserver<Req>) serviceImpl.import_(
601 …(io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallResponse>) responseOb…
609 …implements io.grpc.protobuf.ProtoFileDescriptorSupplier, io.grpc.protobuf.ProtoServiceDescriptorSu…
614 return io.grpc.testing.compiler.Test.getDescriptor();
630 implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
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)