| package io.grpc.testing.integration; |
| |
| 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; |
| import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall; |
| import static io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall; |
| |
| /** |
| * <pre> |
| * Test service that supports all call types. |
| * </pre> |
| */ |
| @javax.annotation.Generated( |
| value = "by gRPC proto compiler (version 0.15.0-SNAPSHOT)", |
| comments = "Source: test.proto") |
| public class TestServiceGrpc { |
| |
| private TestServiceGrpc() {} |
| |
| public static final String SERVICE_NAME = "grpc.testing.TestService"; |
| |
| // Static method descriptors that strictly reflect the proto. |
| @io.grpc.ExperimentalApi |
| public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.SimpleRequest, |
| io.grpc.testing.integration.Test.SimpleResponse> METHOD_UNARY_CALL = |
| io.grpc.MethodDescriptor.create( |
| io.grpc.MethodDescriptor.MethodType.UNARY, |
| generateFullMethodName( |
| "grpc.testing.TestService", "UnaryCall"), |
| io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.testing.integration.Test.SimpleRequest.getDefaultInstance()), |
| io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.testing.integration.Test.SimpleResponse.getDefaultInstance())); |
| @io.grpc.ExperimentalApi |
| public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest, |
| io.grpc.testing.integration.Test.StreamingOutputCallResponse> METHOD_STREAMING_OUTPUT_CALL = |
| io.grpc.MethodDescriptor.create( |
| io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING, |
| generateFullMethodName( |
| "grpc.testing.TestService", "StreamingOutputCall"), |
| io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.testing.integration.Test.StreamingOutputCallRequest.getDefaultInstance()), |
| io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.testing.integration.Test.StreamingOutputCallResponse.getDefaultInstance())); |
| @io.grpc.ExperimentalApi |
| public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingInputCallRequest, |
| io.grpc.testing.integration.Test.StreamingInputCallResponse> METHOD_STREAMING_INPUT_CALL = |
| io.grpc.MethodDescriptor.create( |
| io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING, |
| generateFullMethodName( |
| "grpc.testing.TestService", "StreamingInputCall"), |
| io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.testing.integration.Test.StreamingInputCallRequest.getDefaultInstance()), |
| io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.testing.integration.Test.StreamingInputCallResponse.getDefaultInstance())); |
| @io.grpc.ExperimentalApi |
| public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest, |
| io.grpc.testing.integration.Test.StreamingOutputCallResponse> METHOD_FULL_BIDI_CALL = |
| io.grpc.MethodDescriptor.create( |
| io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING, |
| generateFullMethodName( |
| "grpc.testing.TestService", "FullBidiCall"), |
| io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.testing.integration.Test.StreamingOutputCallRequest.getDefaultInstance()), |
| io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.testing.integration.Test.StreamingOutputCallResponse.getDefaultInstance())); |
| @io.grpc.ExperimentalApi |
| public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest, |
| io.grpc.testing.integration.Test.StreamingOutputCallResponse> METHOD_HALF_BIDI_CALL = |
| io.grpc.MethodDescriptor.create( |
| io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING, |
| generateFullMethodName( |
| "grpc.testing.TestService", "HalfBidiCall"), |
| io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.testing.integration.Test.StreamingOutputCallRequest.getDefaultInstance()), |
| io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.testing.integration.Test.StreamingOutputCallResponse.getDefaultInstance())); |
| |
| /** |
| * Creates a new async stub that supports all call types for the service |
| */ |
| public static TestServiceStub newStub(io.grpc.Channel channel) { |
| return new TestServiceStub(channel); |
| } |
| |
| /** |
| * Creates a new blocking-style stub that supports unary and streaming output calls on the service |
| */ |
| public static TestServiceBlockingStub newBlockingStub( |
| io.grpc.Channel channel) { |
| return new TestServiceBlockingStub(channel); |
| } |
| |
| /** |
| * Creates a new ListenableFuture-style stub that supports unary and streaming output calls on the service |
| */ |
| public static TestServiceFutureStub newFutureStub( |
| io.grpc.Channel channel) { |
| return new TestServiceFutureStub(channel); |
| } |
| |
| /** |
| * <pre> |
| * Test service that supports all call types. |
| * </pre> |
| */ |
| public static interface TestService { |
| |
| /** |
| * <pre> |
| * One request followed by one response. |
| * The server returns the client payload as-is. |
| * </pre> |
| */ |
| public void unaryCall(io.grpc.testing.integration.Test.SimpleRequest request, |
| io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.SimpleResponse> responseObserver); |
| |
| /** |
| * <pre> |
| * One request followed by a sequence of responses (streamed download). |
| * The server returns the payload with client desired type and sizes. |
| * </pre> |
| */ |
| public void streamingOutputCall(io.grpc.testing.integration.Test.StreamingOutputCallRequest request, |
| io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallResponse> responseObserver); |
| |
| /** |
| * <pre> |
| * A sequence of requests followed by one response (streamed upload). |
| * The server returns the aggregated size of client payload as the result. |
| * </pre> |
| */ |
| public io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingInputCallRequest> streamingInputCall( |
| io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingInputCallResponse> responseObserver); |
| |
| /** |
| * <pre> |
| * A sequence of requests with each request served by the server immediately. |
| * As one request could lead to multiple responses, this interface |
| * demonstrates the idea of full bidirectionality. |
| * </pre> |
| */ |
| public io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallRequest> fullBidiCall( |
| io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallResponse> responseObserver); |
| |
| /** |
| * <pre> |
| * A sequence of requests followed by a sequence of responses. |
| * The server buffers all the client requests and then serves them in order. A |
| * stream of responses are returned to the client when the server starts with |
| * first request. |
| * </pre> |
| */ |
| public io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallRequest> halfBidiCall( |
| io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallResponse> responseObserver); |
| } |
| |
| @io.grpc.ExperimentalApi |
| public static abstract class AbstractTestService implements TestService, io.grpc.BindableService { |
| |
| @java.lang.Override |
| public void unaryCall(io.grpc.testing.integration.Test.SimpleRequest request, |
| io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.SimpleResponse> responseObserver) { |
| asyncUnimplementedUnaryCall(METHOD_UNARY_CALL, responseObserver); |
| } |
| |
| @java.lang.Override |
| public void streamingOutputCall(io.grpc.testing.integration.Test.StreamingOutputCallRequest request, |
| io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallResponse> responseObserver) { |
| asyncUnimplementedUnaryCall(METHOD_STREAMING_OUTPUT_CALL, responseObserver); |
| } |
| |
| @java.lang.Override |
| public io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingInputCallRequest> streamingInputCall( |
| io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingInputCallResponse> responseObserver) { |
| return asyncUnimplementedStreamingCall(METHOD_STREAMING_INPUT_CALL, responseObserver); |
| } |
| |
| @java.lang.Override |
| public io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallRequest> fullBidiCall( |
| io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallResponse> responseObserver) { |
| return asyncUnimplementedStreamingCall(METHOD_FULL_BIDI_CALL, responseObserver); |
| } |
| |
| @java.lang.Override |
| public io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallRequest> halfBidiCall( |
| io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallResponse> responseObserver) { |
| return asyncUnimplementedStreamingCall(METHOD_HALF_BIDI_CALL, responseObserver); |
| } |
| |
| @java.lang.Override public io.grpc.ServerServiceDefinition bindService() { |
| return TestServiceGrpc.bindService(this); |
| } |
| } |
| |
| /** |
| * <pre> |
| * Test service that supports all call types. |
| * </pre> |
| */ |
| public static interface TestServiceBlockingClient { |
| |
| /** |
| * <pre> |
| * One request followed by one response. |
| * The server returns the client payload as-is. |
| * </pre> |
| */ |
| public io.grpc.testing.integration.Test.SimpleResponse unaryCall(io.grpc.testing.integration.Test.SimpleRequest request); |
| |
| /** |
| * <pre> |
| * One request followed by a sequence of responses (streamed download). |
| * The server returns the payload with client desired type and sizes. |
| * </pre> |
| */ |
| public java.util.Iterator<io.grpc.testing.integration.Test.StreamingOutputCallResponse> streamingOutputCall( |
| io.grpc.testing.integration.Test.StreamingOutputCallRequest request); |
| } |
| |
| /** |
| * <pre> |
| * Test service that supports all call types. |
| * </pre> |
| */ |
| public static interface TestServiceFutureClient { |
| |
| /** |
| * <pre> |
| * One request followed by one response. |
| * The server returns the client payload as-is. |
| * </pre> |
| */ |
| public com.google.common.util.concurrent.ListenableFuture<io.grpc.testing.integration.Test.SimpleResponse> unaryCall( |
| io.grpc.testing.integration.Test.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.Test.SimpleRequest request, |
| io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.SimpleResponse> responseObserver) { |
| asyncUnaryCall( |
| getChannel().newCall(METHOD_UNARY_CALL, getCallOptions()), request, responseObserver); |
| } |
| |
| @java.lang.Override |
| public void streamingOutputCall(io.grpc.testing.integration.Test.StreamingOutputCallRequest request, |
| io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallResponse> responseObserver) { |
| asyncServerStreamingCall( |
| getChannel().newCall(METHOD_STREAMING_OUTPUT_CALL, getCallOptions()), request, responseObserver); |
| } |
| |
| @java.lang.Override |
| public io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingInputCallRequest> streamingInputCall( |
| io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingInputCallResponse> responseObserver) { |
| return asyncClientStreamingCall( |
| getChannel().newCall(METHOD_STREAMING_INPUT_CALL, getCallOptions()), responseObserver); |
| } |
| |
| @java.lang.Override |
| public io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallRequest> fullBidiCall( |
| io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallResponse> responseObserver) { |
| return asyncBidiStreamingCall( |
| getChannel().newCall(METHOD_FULL_BIDI_CALL, getCallOptions()), responseObserver); |
| } |
| |
| @java.lang.Override |
| public io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallRequest> halfBidiCall( |
| io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.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.Test.SimpleResponse unaryCall(io.grpc.testing.integration.Test.SimpleRequest request) { |
| return blockingUnaryCall( |
| getChannel(), METHOD_UNARY_CALL, getCallOptions(), request); |
| } |
| |
| @java.lang.Override |
| public java.util.Iterator<io.grpc.testing.integration.Test.StreamingOutputCallResponse> streamingOutputCall( |
| io.grpc.testing.integration.Test.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.Test.SimpleResponse> unaryCall( |
| io.grpc.testing.integration.Test.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.Test.SimpleRequest) request, |
| (io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.SimpleResponse>) responseObserver); |
| break; |
| case METHODID_STREAMING_OUTPUT_CALL: |
| serviceImpl.streamingOutputCall((io.grpc.testing.integration.Test.StreamingOutputCallRequest) request, |
| (io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.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.Test.StreamingInputCallResponse>) responseObserver); |
| case METHODID_FULL_BIDI_CALL: |
| return (io.grpc.stub.StreamObserver<Req>) serviceImpl.fullBidiCall( |
| (io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallResponse>) responseObserver); |
| case METHODID_HALF_BIDI_CALL: |
| return (io.grpc.stub.StreamObserver<Req>) serviceImpl.halfBidiCall( |
| (io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.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.Test.SimpleRequest, |
| io.grpc.testing.integration.Test.SimpleResponse>( |
| serviceImpl, METHODID_UNARY_CALL))) |
| .addMethod( |
| METHOD_STREAMING_OUTPUT_CALL, |
| asyncServerStreamingCall( |
| new MethodHandlers< |
| io.grpc.testing.integration.Test.StreamingOutputCallRequest, |
| io.grpc.testing.integration.Test.StreamingOutputCallResponse>( |
| serviceImpl, METHODID_STREAMING_OUTPUT_CALL))) |
| .addMethod( |
| METHOD_STREAMING_INPUT_CALL, |
| asyncClientStreamingCall( |
| new MethodHandlers< |
| io.grpc.testing.integration.Test.StreamingInputCallRequest, |
| io.grpc.testing.integration.Test.StreamingInputCallResponse>( |
| serviceImpl, METHODID_STREAMING_INPUT_CALL))) |
| .addMethod( |
| METHOD_FULL_BIDI_CALL, |
| asyncBidiStreamingCall( |
| new MethodHandlers< |
| io.grpc.testing.integration.Test.StreamingOutputCallRequest, |
| io.grpc.testing.integration.Test.StreamingOutputCallResponse>( |
| serviceImpl, METHODID_FULL_BIDI_CALL))) |
| .addMethod( |
| METHOD_HALF_BIDI_CALL, |
| asyncBidiStreamingCall( |
| new MethodHandlers< |
| io.grpc.testing.integration.Test.StreamingOutputCallRequest, |
| io.grpc.testing.integration.Test.StreamingOutputCallResponse>( |
| serviceImpl, METHODID_HALF_BIDI_CALL))) |
| .build(); |
| } |
| } |