diff options
Diffstat (limited to 'compiler/src/test/golden/TestServiceLite.java.txt')
| -rw-r--r-- | compiler/src/test/golden/TestServiceLite.java.txt | 323 |
1 files changed, 323 insertions, 0 deletions
diff --git a/compiler/src/test/golden/TestServiceLite.java.txt b/compiler/src/test/golden/TestServiceLite.java.txt new file mode 100644 index 000000000..86da7e77e --- /dev/null +++ b/compiler/src/test/golden/TestServiceLite.java.txt @@ -0,0 +1,323 @@ +package io.grpc.testing.integration.lite; + +import static io.grpc.stub.ClientCalls.asyncUnaryCall; +import static io.grpc.stub.ClientCalls.asyncServerStreamingCall; +import static io.grpc.stub.ClientCalls.asyncClientStreamingCall; +import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall; +import static io.grpc.stub.ClientCalls.blockingUnaryCall; +import static io.grpc.stub.ClientCalls.blockingServerStreamingCall; +import static io.grpc.stub.ClientCalls.futureUnaryCall; +import static io.grpc.MethodDescriptor.generateFullMethodName; +import static io.grpc.stub.ServerCalls.asyncUnaryCall; +import static io.grpc.stub.ServerCalls.asyncServerStreamingCall; +import static io.grpc.stub.ServerCalls.asyncClientStreamingCall; +import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall; + +@javax.annotation.Generated( + value = "by gRPC proto compiler", + comments = "Source: test_lite.proto") +public class TestServiceGrpc { + + private TestServiceGrpc() {} + + public static final String SERVICE_NAME = "grpc.testing.lite.TestService"; + + // Static method descriptors that strictly reflect the proto. + @io.grpc.ExperimentalApi + public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.lite.TestLite.SimpleRequest, + io.grpc.testing.integration.lite.TestLite.SimpleResponse> METHOD_UNARY_CALL = + io.grpc.MethodDescriptor.create( + io.grpc.MethodDescriptor.MethodType.UNARY, + generateFullMethodName( + "grpc.testing.lite.TestService", "UnaryCall"), + io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(io.grpc.testing.integration.lite.TestLite.SimpleRequest.getDefaultInstance()), + io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(io.grpc.testing.integration.lite.TestLite.SimpleResponse.getDefaultInstance())); + @io.grpc.ExperimentalApi + public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.lite.TestLite.StreamingOutputCallRequest, + io.grpc.testing.integration.lite.TestLite.StreamingOutputCallResponse> METHOD_STREAMING_OUTPUT_CALL = + io.grpc.MethodDescriptor.create( + io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING, + generateFullMethodName( + "grpc.testing.lite.TestService", "StreamingOutputCall"), + io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(io.grpc.testing.integration.lite.TestLite.StreamingOutputCallRequest.getDefaultInstance()), + io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(io.grpc.testing.integration.lite.TestLite.StreamingOutputCallResponse.getDefaultInstance())); + @io.grpc.ExperimentalApi + public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.lite.TestLite.StreamingInputCallRequest, + io.grpc.testing.integration.lite.TestLite.StreamingInputCallResponse> METHOD_STREAMING_INPUT_CALL = + io.grpc.MethodDescriptor.create( + io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING, + generateFullMethodName( + "grpc.testing.lite.TestService", "StreamingInputCall"), + io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(io.grpc.testing.integration.lite.TestLite.StreamingInputCallRequest.getDefaultInstance()), + io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(io.grpc.testing.integration.lite.TestLite.StreamingInputCallResponse.getDefaultInstance())); + @io.grpc.ExperimentalApi + public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.lite.TestLite.StreamingOutputCallRequest, + io.grpc.testing.integration.lite.TestLite.StreamingOutputCallResponse> METHOD_FULL_BIDI_CALL = + io.grpc.MethodDescriptor.create( + io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING, + generateFullMethodName( + "grpc.testing.lite.TestService", "FullBidiCall"), + io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(io.grpc.testing.integration.lite.TestLite.StreamingOutputCallRequest.getDefaultInstance()), + io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(io.grpc.testing.integration.lite.TestLite.StreamingOutputCallResponse.getDefaultInstance())); + @io.grpc.ExperimentalApi + public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.lite.TestLite.StreamingOutputCallRequest, + io.grpc.testing.integration.lite.TestLite.StreamingOutputCallResponse> METHOD_HALF_BIDI_CALL = + io.grpc.MethodDescriptor.create( + io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING, + generateFullMethodName( + "grpc.testing.lite.TestService", "HalfBidiCall"), + io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(io.grpc.testing.integration.lite.TestLite.StreamingOutputCallRequest.getDefaultInstance()), + io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(io.grpc.testing.integration.lite.TestLite.StreamingOutputCallResponse.getDefaultInstance())); + + public static TestServiceStub newStub(io.grpc.Channel channel) { + return new TestServiceStub(channel); + } + + public static TestServiceBlockingStub newBlockingStub( + io.grpc.Channel channel) { + return new TestServiceBlockingStub(channel); + } + + public static TestServiceFutureStub newFutureStub( + io.grpc.Channel channel) { + return new TestServiceFutureStub(channel); + } + + public static interface TestService { + + public void unaryCall(io.grpc.testing.integration.lite.TestLite.SimpleRequest request, + io.grpc.stub.StreamObserver<io.grpc.testing.integration.lite.TestLite.SimpleResponse> responseObserver); + + public void streamingOutputCall(io.grpc.testing.integration.lite.TestLite.StreamingOutputCallRequest request, + io.grpc.stub.StreamObserver<io.grpc.testing.integration.lite.TestLite.StreamingOutputCallResponse> responseObserver); + + public io.grpc.stub.StreamObserver<io.grpc.testing.integration.lite.TestLite.StreamingInputCallRequest> streamingInputCall( + io.grpc.stub.StreamObserver<io.grpc.testing.integration.lite.TestLite.StreamingInputCallResponse> responseObserver); + + public io.grpc.stub.StreamObserver<io.grpc.testing.integration.lite.TestLite.StreamingOutputCallRequest> fullBidiCall( + io.grpc.stub.StreamObserver<io.grpc.testing.integration.lite.TestLite.StreamingOutputCallResponse> responseObserver); + + public io.grpc.stub.StreamObserver<io.grpc.testing.integration.lite.TestLite.StreamingOutputCallRequest> halfBidiCall( + io.grpc.stub.StreamObserver<io.grpc.testing.integration.lite.TestLite.StreamingOutputCallResponse> responseObserver); + } + + public static interface TestServiceBlockingClient { + + public io.grpc.testing.integration.lite.TestLite.SimpleResponse unaryCall(io.grpc.testing.integration.lite.TestLite.SimpleRequest request); + + public java.util.Iterator<io.grpc.testing.integration.lite.TestLite.StreamingOutputCallResponse> streamingOutputCall( + io.grpc.testing.integration.lite.TestLite.StreamingOutputCallRequest request); + } + + public static interface TestServiceFutureClient { + + public com.google.common.util.concurrent.ListenableFuture<io.grpc.testing.integration.lite.TestLite.SimpleResponse> unaryCall( + io.grpc.testing.integration.lite.TestLite.SimpleRequest request); + } + + public static class TestServiceStub extends io.grpc.stub.AbstractStub<TestServiceStub> + implements TestService { + private TestServiceStub(io.grpc.Channel channel) { + super(channel); + } + + private TestServiceStub(io.grpc.Channel channel, + io.grpc.CallOptions callOptions) { + super(channel, callOptions); + } + + @java.lang.Override + protected TestServiceStub build(io.grpc.Channel channel, + io.grpc.CallOptions callOptions) { + return new TestServiceStub(channel, callOptions); + } + + @java.lang.Override + public void unaryCall(io.grpc.testing.integration.lite.TestLite.SimpleRequest request, + io.grpc.stub.StreamObserver<io.grpc.testing.integration.lite.TestLite.SimpleResponse> responseObserver) { + asyncUnaryCall( + getChannel().newCall(METHOD_UNARY_CALL, getCallOptions()), request, responseObserver); + } + + @java.lang.Override + public void streamingOutputCall(io.grpc.testing.integration.lite.TestLite.StreamingOutputCallRequest request, + io.grpc.stub.StreamObserver<io.grpc.testing.integration.lite.TestLite.StreamingOutputCallResponse> responseObserver) { + asyncServerStreamingCall( + getChannel().newCall(METHOD_STREAMING_OUTPUT_CALL, getCallOptions()), request, responseObserver); + } + + @java.lang.Override + public io.grpc.stub.StreamObserver<io.grpc.testing.integration.lite.TestLite.StreamingInputCallRequest> streamingInputCall( + io.grpc.stub.StreamObserver<io.grpc.testing.integration.lite.TestLite.StreamingInputCallResponse> responseObserver) { + return asyncClientStreamingCall( + getChannel().newCall(METHOD_STREAMING_INPUT_CALL, getCallOptions()), responseObserver); + } + + @java.lang.Override + public io.grpc.stub.StreamObserver<io.grpc.testing.integration.lite.TestLite.StreamingOutputCallRequest> fullBidiCall( + io.grpc.stub.StreamObserver<io.grpc.testing.integration.lite.TestLite.StreamingOutputCallResponse> responseObserver) { + return asyncBidiStreamingCall( + getChannel().newCall(METHOD_FULL_BIDI_CALL, getCallOptions()), responseObserver); + } + + @java.lang.Override + public io.grpc.stub.StreamObserver<io.grpc.testing.integration.lite.TestLite.StreamingOutputCallRequest> halfBidiCall( + io.grpc.stub.StreamObserver<io.grpc.testing.integration.lite.TestLite.StreamingOutputCallResponse> responseObserver) { + return asyncBidiStreamingCall( + getChannel().newCall(METHOD_HALF_BIDI_CALL, getCallOptions()), responseObserver); + } + } + + public static class TestServiceBlockingStub extends io.grpc.stub.AbstractStub<TestServiceBlockingStub> + implements TestServiceBlockingClient { + private TestServiceBlockingStub(io.grpc.Channel channel) { + super(channel); + } + + private TestServiceBlockingStub(io.grpc.Channel channel, + io.grpc.CallOptions callOptions) { + super(channel, callOptions); + } + + @java.lang.Override + protected TestServiceBlockingStub build(io.grpc.Channel channel, + io.grpc.CallOptions callOptions) { + return new TestServiceBlockingStub(channel, callOptions); + } + + @java.lang.Override + public io.grpc.testing.integration.lite.TestLite.SimpleResponse unaryCall(io.grpc.testing.integration.lite.TestLite.SimpleRequest request) { + return blockingUnaryCall( + getChannel(), METHOD_UNARY_CALL, getCallOptions(), request); + } + + @java.lang.Override + public java.util.Iterator<io.grpc.testing.integration.lite.TestLite.StreamingOutputCallResponse> streamingOutputCall( + io.grpc.testing.integration.lite.TestLite.StreamingOutputCallRequest request) { + return blockingServerStreamingCall( + getChannel(), METHOD_STREAMING_OUTPUT_CALL, getCallOptions(), request); + } + } + + public static class TestServiceFutureStub extends io.grpc.stub.AbstractStub<TestServiceFutureStub> + implements TestServiceFutureClient { + private TestServiceFutureStub(io.grpc.Channel channel) { + super(channel); + } + + private TestServiceFutureStub(io.grpc.Channel channel, + io.grpc.CallOptions callOptions) { + super(channel, callOptions); + } + + @java.lang.Override + protected TestServiceFutureStub build(io.grpc.Channel channel, + io.grpc.CallOptions callOptions) { + return new TestServiceFutureStub(channel, callOptions); + } + + @java.lang.Override + public com.google.common.util.concurrent.ListenableFuture<io.grpc.testing.integration.lite.TestLite.SimpleResponse> unaryCall( + io.grpc.testing.integration.lite.TestLite.SimpleRequest request) { + return futureUnaryCall( + getChannel().newCall(METHOD_UNARY_CALL, getCallOptions()), request); + } + } + + private static final int METHODID_UNARY_CALL = 0; + private static final int METHODID_STREAMING_OUTPUT_CALL = 1; + private static final int METHODID_STREAMING_INPUT_CALL = 2; + private static final int METHODID_FULL_BIDI_CALL = 3; + private static final int METHODID_HALF_BIDI_CALL = 4; + + private static class MethodHandlers<Req, Resp> implements + io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>, + io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>, + io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>, + io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> { + private final TestService serviceImpl; + private final int methodId; + + public MethodHandlers(TestService serviceImpl, int methodId) { + this.serviceImpl = serviceImpl; + this.methodId = methodId; + } + + @java.lang.Override + @java.lang.SuppressWarnings("unchecked") + public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) { + switch (methodId) { + case METHODID_UNARY_CALL: + serviceImpl.unaryCall((io.grpc.testing.integration.lite.TestLite.SimpleRequest) request, + (io.grpc.stub.StreamObserver<io.grpc.testing.integration.lite.TestLite.SimpleResponse>) responseObserver); + break; + case METHODID_STREAMING_OUTPUT_CALL: + serviceImpl.streamingOutputCall((io.grpc.testing.integration.lite.TestLite.StreamingOutputCallRequest) request, + (io.grpc.stub.StreamObserver<io.grpc.testing.integration.lite.TestLite.StreamingOutputCallResponse>) responseObserver); + break; + default: + throw new AssertionError(); + } + } + + @java.lang.Override + @java.lang.SuppressWarnings("unchecked") + public io.grpc.stub.StreamObserver<Req> invoke( + io.grpc.stub.StreamObserver<Resp> responseObserver) { + switch (methodId) { + case METHODID_STREAMING_INPUT_CALL: + return (io.grpc.stub.StreamObserver<Req>) serviceImpl.streamingInputCall( + (io.grpc.stub.StreamObserver<io.grpc.testing.integration.lite.TestLite.StreamingInputCallResponse>) responseObserver); + case METHODID_FULL_BIDI_CALL: + return (io.grpc.stub.StreamObserver<Req>) serviceImpl.fullBidiCall( + (io.grpc.stub.StreamObserver<io.grpc.testing.integration.lite.TestLite.StreamingOutputCallResponse>) responseObserver); + case METHODID_HALF_BIDI_CALL: + return (io.grpc.stub.StreamObserver<Req>) serviceImpl.halfBidiCall( + (io.grpc.stub.StreamObserver<io.grpc.testing.integration.lite.TestLite.StreamingOutputCallResponse>) responseObserver); + default: + throw new AssertionError(); + } + } + } + + public static io.grpc.ServerServiceDefinition bindService( + final TestService serviceImpl) { + return io.grpc.ServerServiceDefinition.builder(SERVICE_NAME) + .addMethod( + METHOD_UNARY_CALL, + asyncUnaryCall( + new MethodHandlers< + io.grpc.testing.integration.lite.TestLite.SimpleRequest, + io.grpc.testing.integration.lite.TestLite.SimpleResponse>( + serviceImpl, METHODID_UNARY_CALL))) + .addMethod( + METHOD_STREAMING_OUTPUT_CALL, + asyncServerStreamingCall( + new MethodHandlers< + io.grpc.testing.integration.lite.TestLite.StreamingOutputCallRequest, + io.grpc.testing.integration.lite.TestLite.StreamingOutputCallResponse>( + serviceImpl, METHODID_STREAMING_OUTPUT_CALL))) + .addMethod( + METHOD_STREAMING_INPUT_CALL, + asyncClientStreamingCall( + new MethodHandlers< + io.grpc.testing.integration.lite.TestLite.StreamingInputCallRequest, + io.grpc.testing.integration.lite.TestLite.StreamingInputCallResponse>( + serviceImpl, METHODID_STREAMING_INPUT_CALL))) + .addMethod( + METHOD_FULL_BIDI_CALL, + asyncBidiStreamingCall( + new MethodHandlers< + io.grpc.testing.integration.lite.TestLite.StreamingOutputCallRequest, + io.grpc.testing.integration.lite.TestLite.StreamingOutputCallResponse>( + serviceImpl, METHODID_FULL_BIDI_CALL))) + .addMethod( + METHOD_HALF_BIDI_CALL, + asyncBidiStreamingCall( + new MethodHandlers< + io.grpc.testing.integration.lite.TestLite.StreamingOutputCallRequest, + io.grpc.testing.integration.lite.TestLite.StreamingOutputCallResponse>( + serviceImpl, METHODID_HALF_BIDI_CALL))) + .build(); + } +} |