• Home
  • Raw
  • Download

Lines Matching full:grpc

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;
26     value = "by gRPC proto compiler (version 1.16.1)",
27     comments = "Source: grpc/testing/compiler/test.proto")
32   public static final String SERVICE_NAME = "grpc.testing.compiler.TestService";
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)
50                   "grpc.testing.compiler.TestService", "UnaryCall"))
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)
78                   "grpc.testing.compiler.TestService", "StreamingOutputCall"))
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)
106                   "grpc.testing.compiler.TestService", "StreamingInputCall"))
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)
134                   "grpc.testing.compiler.TestService", "FullBidiCall"))
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)
162                   "grpc.testing.compiler.TestService", "HalfBidiCall"))
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)
190                   "grpc.testing.compiler.TestService", "Import"))
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)