| package io.grpc.testing.compiler; |
| |
| import static io.grpc.MethodDescriptor.generateFullMethodName; |
| |
| /** |
| * <pre> |
| * Test service that supports all call types. |
| * </pre> |
| */ |
| @javax.annotation.Generated( |
| value = "by gRPC proto compiler (version 1.56.1-SNAPSHOT)", |
| comments = "Source: grpc/testing/compiler/test.proto") |
| @io.grpc.stub.annotations.GrpcGenerated |
| public final class TestServiceGrpc { |
| |
| private TestServiceGrpc() {} |
| |
| public static final String SERVICE_NAME = "grpc.testing.compiler.TestService"; |
| |
| // Static method descriptors that strictly reflect the proto. |
| private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest, |
| io.grpc.testing.compiler.Test.SimpleResponse> getUnaryCallMethod; |
| |
| @io.grpc.stub.annotations.RpcMethod( |
| fullMethodName = SERVICE_NAME + '/' + "UnaryCall", |
| requestType = io.grpc.testing.compiler.Test.SimpleRequest.class, |
| responseType = io.grpc.testing.compiler.Test.SimpleResponse.class, |
| methodType = io.grpc.MethodDescriptor.MethodType.UNARY) |
| public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest, |
| io.grpc.testing.compiler.Test.SimpleResponse> getUnaryCallMethod() { |
| io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Test.SimpleResponse> getUnaryCallMethod; |
| if ((getUnaryCallMethod = TestServiceGrpc.getUnaryCallMethod) == null) { |
| synchronized (TestServiceGrpc.class) { |
| if ((getUnaryCallMethod = TestServiceGrpc.getUnaryCallMethod) == null) { |
| TestServiceGrpc.getUnaryCallMethod = getUnaryCallMethod = |
| io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Test.SimpleResponse>newBuilder() |
| .setType(io.grpc.MethodDescriptor.MethodType.UNARY) |
| .setFullMethodName(generateFullMethodName(SERVICE_NAME, "UnaryCall")) |
| .setSampledToLocalTracing(true) |
| .setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( |
| io.grpc.testing.compiler.Test.SimpleRequest.getDefaultInstance())) |
| .setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( |
| io.grpc.testing.compiler.Test.SimpleResponse.getDefaultInstance())) |
| .build(); |
| } |
| } |
| } |
| return getUnaryCallMethod; |
| } |
| |
| private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, |
| io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod; |
| |
| @io.grpc.stub.annotations.RpcMethod( |
| fullMethodName = SERVICE_NAME + '/' + "StreamingOutputCall", |
| requestType = io.grpc.testing.compiler.Test.StreamingOutputCallRequest.class, |
| responseType = io.grpc.testing.compiler.Test.StreamingOutputCallResponse.class, |
| methodType = io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) |
| public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, |
| io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod() { |
| io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod; |
| if ((getStreamingOutputCallMethod = TestServiceGrpc.getStreamingOutputCallMethod) == null) { |
| synchronized (TestServiceGrpc.class) { |
| if ((getStreamingOutputCallMethod = TestServiceGrpc.getStreamingOutputCallMethod) == null) { |
| TestServiceGrpc.getStreamingOutputCallMethod = getStreamingOutputCallMethod = |
| io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse>newBuilder() |
| .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) |
| .setFullMethodName(generateFullMethodName(SERVICE_NAME, "StreamingOutputCall")) |
| .setSampledToLocalTracing(true) |
| .setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( |
| io.grpc.testing.compiler.Test.StreamingOutputCallRequest.getDefaultInstance())) |
| .setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( |
| io.grpc.testing.compiler.Test.StreamingOutputCallResponse.getDefaultInstance())) |
| .build(); |
| } |
| } |
| } |
| return getStreamingOutputCallMethod; |
| } |
| |
| private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest, |
| io.grpc.testing.compiler.Test.StreamingInputCallResponse> getStreamingInputCallMethod; |
| |
| @io.grpc.stub.annotations.RpcMethod( |
| fullMethodName = SERVICE_NAME + '/' + "StreamingInputCall", |
| requestType = io.grpc.testing.compiler.Test.StreamingInputCallRequest.class, |
| responseType = io.grpc.testing.compiler.Test.StreamingInputCallResponse.class, |
| methodType = io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING) |
| public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest, |
| io.grpc.testing.compiler.Test.StreamingInputCallResponse> getStreamingInputCallMethod() { |
| io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest, io.grpc.testing.compiler.Test.StreamingInputCallResponse> getStreamingInputCallMethod; |
| if ((getStreamingInputCallMethod = TestServiceGrpc.getStreamingInputCallMethod) == null) { |
| synchronized (TestServiceGrpc.class) { |
| if ((getStreamingInputCallMethod = TestServiceGrpc.getStreamingInputCallMethod) == null) { |
| TestServiceGrpc.getStreamingInputCallMethod = getStreamingInputCallMethod = |
| io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingInputCallRequest, io.grpc.testing.compiler.Test.StreamingInputCallResponse>newBuilder() |
| .setType(io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING) |
| .setFullMethodName(generateFullMethodName(SERVICE_NAME, "StreamingInputCall")) |
| .setSampledToLocalTracing(true) |
| .setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( |
| io.grpc.testing.compiler.Test.StreamingInputCallRequest.getDefaultInstance())) |
| .setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( |
| io.grpc.testing.compiler.Test.StreamingInputCallResponse.getDefaultInstance())) |
| .build(); |
| } |
| } |
| } |
| return getStreamingInputCallMethod; |
| } |
| |
| private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, |
| io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getFullBidiCallMethod; |
| |
| @io.grpc.stub.annotations.RpcMethod( |
| fullMethodName = SERVICE_NAME + '/' + "FullBidiCall", |
| requestType = io.grpc.testing.compiler.Test.StreamingOutputCallRequest.class, |
| responseType = io.grpc.testing.compiler.Test.StreamingOutputCallResponse.class, |
| methodType = io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) |
| public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, |
| io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getFullBidiCallMethod() { |
| io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getFullBidiCallMethod; |
| if ((getFullBidiCallMethod = TestServiceGrpc.getFullBidiCallMethod) == null) { |
| synchronized (TestServiceGrpc.class) { |
| if ((getFullBidiCallMethod = TestServiceGrpc.getFullBidiCallMethod) == null) { |
| TestServiceGrpc.getFullBidiCallMethod = getFullBidiCallMethod = |
| io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse>newBuilder() |
| .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) |
| .setFullMethodName(generateFullMethodName(SERVICE_NAME, "FullBidiCall")) |
| .setSampledToLocalTracing(true) |
| .setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( |
| io.grpc.testing.compiler.Test.StreamingOutputCallRequest.getDefaultInstance())) |
| .setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( |
| io.grpc.testing.compiler.Test.StreamingOutputCallResponse.getDefaultInstance())) |
| .build(); |
| } |
| } |
| } |
| return getFullBidiCallMethod; |
| } |
| |
| private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, |
| io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getHalfBidiCallMethod; |
| |
| @io.grpc.stub.annotations.RpcMethod( |
| fullMethodName = SERVICE_NAME + '/' + "HalfBidiCall", |
| requestType = io.grpc.testing.compiler.Test.StreamingOutputCallRequest.class, |
| responseType = io.grpc.testing.compiler.Test.StreamingOutputCallResponse.class, |
| methodType = io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) |
| public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, |
| io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getHalfBidiCallMethod() { |
| io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getHalfBidiCallMethod; |
| if ((getHalfBidiCallMethod = TestServiceGrpc.getHalfBidiCallMethod) == null) { |
| synchronized (TestServiceGrpc.class) { |
| if ((getHalfBidiCallMethod = TestServiceGrpc.getHalfBidiCallMethod) == null) { |
| TestServiceGrpc.getHalfBidiCallMethod = getHalfBidiCallMethod = |
| io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse>newBuilder() |
| .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) |
| .setFullMethodName(generateFullMethodName(SERVICE_NAME, "HalfBidiCall")) |
| .setSampledToLocalTracing(true) |
| .setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( |
| io.grpc.testing.compiler.Test.StreamingOutputCallRequest.getDefaultInstance())) |
| .setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( |
| io.grpc.testing.compiler.Test.StreamingOutputCallResponse.getDefaultInstance())) |
| .build(); |
| } |
| } |
| } |
| return getHalfBidiCallMethod; |
| } |
| |
| private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest, |
| io.grpc.testing.compiler.Test.StreamingInputCallResponse> getImportMethod; |
| |
| @io.grpc.stub.annotations.RpcMethod( |
| fullMethodName = SERVICE_NAME + '/' + "Import", |
| requestType = io.grpc.testing.compiler.Test.StreamingInputCallRequest.class, |
| responseType = io.grpc.testing.compiler.Test.StreamingInputCallResponse.class, |
| methodType = io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) |
| public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest, |
| io.grpc.testing.compiler.Test.StreamingInputCallResponse> getImportMethod() { |
| io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest, io.grpc.testing.compiler.Test.StreamingInputCallResponse> getImportMethod; |
| if ((getImportMethod = TestServiceGrpc.getImportMethod) == null) { |
| synchronized (TestServiceGrpc.class) { |
| if ((getImportMethod = TestServiceGrpc.getImportMethod) == null) { |
| TestServiceGrpc.getImportMethod = getImportMethod = |
| io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingInputCallRequest, io.grpc.testing.compiler.Test.StreamingInputCallResponse>newBuilder() |
| .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) |
| .setFullMethodName(generateFullMethodName(SERVICE_NAME, "Import")) |
| .setSampledToLocalTracing(true) |
| .setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( |
| io.grpc.testing.compiler.Test.StreamingInputCallRequest.getDefaultInstance())) |
| .setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( |
| io.grpc.testing.compiler.Test.StreamingInputCallResponse.getDefaultInstance())) |
| .build(); |
| } |
| } |
| } |
| return getImportMethod; |
| } |
| |
| private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest, |
| io.grpc.testing.compiler.Test.SimpleResponse> getSafeCallMethod; |
| |
| @io.grpc.stub.annotations.RpcMethod( |
| fullMethodName = SERVICE_NAME + '/' + "SafeCall", |
| requestType = io.grpc.testing.compiler.Test.SimpleRequest.class, |
| responseType = io.grpc.testing.compiler.Test.SimpleResponse.class, |
| methodType = io.grpc.MethodDescriptor.MethodType.UNARY) |
| public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest, |
| io.grpc.testing.compiler.Test.SimpleResponse> getSafeCallMethod() { |
| io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Test.SimpleResponse> getSafeCallMethod; |
| if ((getSafeCallMethod = TestServiceGrpc.getSafeCallMethod) == null) { |
| synchronized (TestServiceGrpc.class) { |
| if ((getSafeCallMethod = TestServiceGrpc.getSafeCallMethod) == null) { |
| TestServiceGrpc.getSafeCallMethod = getSafeCallMethod = |
| io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Test.SimpleResponse>newBuilder() |
| .setType(io.grpc.MethodDescriptor.MethodType.UNARY) |
| .setFullMethodName(generateFullMethodName(SERVICE_NAME, "SafeCall")) |
| .setSafe(true) |
| .setSampledToLocalTracing(true) |
| .setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( |
| io.grpc.testing.compiler.Test.SimpleRequest.getDefaultInstance())) |
| .setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( |
| io.grpc.testing.compiler.Test.SimpleResponse.getDefaultInstance())) |
| .build(); |
| } |
| } |
| } |
| return getSafeCallMethod; |
| } |
| |
| private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest, |
| io.grpc.testing.compiler.Test.SimpleResponse> getIdempotentCallMethod; |
| |
| @io.grpc.stub.annotations.RpcMethod( |
| fullMethodName = SERVICE_NAME + '/' + "IdempotentCall", |
| requestType = io.grpc.testing.compiler.Test.SimpleRequest.class, |
| responseType = io.grpc.testing.compiler.Test.SimpleResponse.class, |
| methodType = io.grpc.MethodDescriptor.MethodType.UNARY) |
| public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest, |
| io.grpc.testing.compiler.Test.SimpleResponse> getIdempotentCallMethod() { |
| io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Test.SimpleResponse> getIdempotentCallMethod; |
| if ((getIdempotentCallMethod = TestServiceGrpc.getIdempotentCallMethod) == null) { |
| synchronized (TestServiceGrpc.class) { |
| if ((getIdempotentCallMethod = TestServiceGrpc.getIdempotentCallMethod) == null) { |
| TestServiceGrpc.getIdempotentCallMethod = getIdempotentCallMethod = |
| io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Test.SimpleResponse>newBuilder() |
| .setType(io.grpc.MethodDescriptor.MethodType.UNARY) |
| .setFullMethodName(generateFullMethodName(SERVICE_NAME, "IdempotentCall")) |
| .setIdempotent(true) |
| .setSampledToLocalTracing(true) |
| .setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( |
| io.grpc.testing.compiler.Test.SimpleRequest.getDefaultInstance())) |
| .setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( |
| io.grpc.testing.compiler.Test.SimpleResponse.getDefaultInstance())) |
| .build(); |
| } |
| } |
| } |
| return getIdempotentCallMethod; |
| } |
| |
| /** |
| * Creates a new async stub that supports all call types for the service |
| */ |
| public static TestServiceStub newStub(io.grpc.Channel channel) { |
| io.grpc.stub.AbstractStub.StubFactory<TestServiceStub> factory = |
| new io.grpc.stub.AbstractStub.StubFactory<TestServiceStub>() { |
| @java.lang.Override |
| public TestServiceStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { |
| return new TestServiceStub(channel, callOptions); |
| } |
| }; |
| return TestServiceStub.newStub(factory, 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) { |
| io.grpc.stub.AbstractStub.StubFactory<TestServiceBlockingStub> factory = |
| new io.grpc.stub.AbstractStub.StubFactory<TestServiceBlockingStub>() { |
| @java.lang.Override |
| public TestServiceBlockingStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { |
| return new TestServiceBlockingStub(channel, callOptions); |
| } |
| }; |
| return TestServiceBlockingStub.newStub(factory, channel); |
| } |
| |
| /** |
| * Creates a new ListenableFuture-style stub that supports unary calls on the service |
| */ |
| public static TestServiceFutureStub newFutureStub( |
| io.grpc.Channel channel) { |
| io.grpc.stub.AbstractStub.StubFactory<TestServiceFutureStub> factory = |
| new io.grpc.stub.AbstractStub.StubFactory<TestServiceFutureStub>() { |
| @java.lang.Override |
| public TestServiceFutureStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { |
| return new TestServiceFutureStub(channel, callOptions); |
| } |
| }; |
| return TestServiceFutureStub.newStub(factory, channel); |
| } |
| |
| /** |
| * <pre> |
| * Test service that supports all call types. |
| * </pre> |
| */ |
| public interface AsyncService { |
| |
| /** |
| * <pre> |
| * One request followed by one response. |
| * The server returns the client payload as-is. |
| * </pre> |
| */ |
| default void unaryCall(io.grpc.testing.compiler.Test.SimpleRequest request, |
| io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse> responseObserver) { |
| io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getUnaryCallMethod(), responseObserver); |
| } |
| |
| /** |
| * <pre> |
| * One request followed by a sequence of responses (streamed download). |
| * The server returns the payload with client desired type and sizes. |
| * </pre> |
| */ |
| default void streamingOutputCall(io.grpc.testing.compiler.Test.StreamingOutputCallRequest request, |
| io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObserver) { |
| io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getStreamingOutputCallMethod(), 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> |
| */ |
| default io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallRequest> streamingInputCall( |
| io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallResponse> responseObserver) { |
| return io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall(getStreamingInputCallMethod(), 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> |
| */ |
| default io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallRequest> fullBidiCall( |
| io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObserver) { |
| return io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall(getFullBidiCallMethod(), 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> |
| */ |
| default io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallRequest> halfBidiCall( |
| io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObserver) { |
| return io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall(getHalfBidiCallMethod(), responseObserver); |
| } |
| |
| /** |
| * <pre> |
| * An RPC method whose Java name collides with a keyword, and whose generated |
| * method should have a '_' appended. |
| * </pre> |
| */ |
| default io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallRequest> import_( |
| io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallResponse> responseObserver) { |
| return io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall(getImportMethod(), responseObserver); |
| } |
| |
| /** |
| * <pre> |
| * A unary call that is Safe. |
| * </pre> |
| */ |
| default void safeCall(io.grpc.testing.compiler.Test.SimpleRequest request, |
| io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse> responseObserver) { |
| io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getSafeCallMethod(), responseObserver); |
| } |
| |
| /** |
| * <pre> |
| * A unary call that is Idempotent. |
| * </pre> |
| */ |
| default void idempotentCall(io.grpc.testing.compiler.Test.SimpleRequest request, |
| io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse> responseObserver) { |
| io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getIdempotentCallMethod(), responseObserver); |
| } |
| } |
| |
| /** |
| * Base class for the server implementation of the service TestService. |
| * <pre> |
| * Test service that supports all call types. |
| * </pre> |
| */ |
| public static abstract class TestServiceImplBase |
| implements io.grpc.BindableService, AsyncService { |
| |
| @java.lang.Override public final io.grpc.ServerServiceDefinition bindService() { |
| return TestServiceGrpc.bindService(this); |
| } |
| } |
| |
| /** |
| * A stub to allow clients to do asynchronous rpc calls to service TestService. |
| * <pre> |
| * Test service that supports all call types. |
| * </pre> |
| */ |
| public static final class TestServiceStub |
| extends io.grpc.stub.AbstractAsyncStub<TestServiceStub> { |
| 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); |
| } |
| |
| /** |
| * <pre> |
| * One request followed by one response. |
| * The server returns the client payload as-is. |
| * </pre> |
| */ |
| public void unaryCall(io.grpc.testing.compiler.Test.SimpleRequest request, |
| io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse> responseObserver) { |
| io.grpc.stub.ClientCalls.asyncUnaryCall( |
| getChannel().newCall(getUnaryCallMethod(), getCallOptions()), request, 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.compiler.Test.StreamingOutputCallRequest request, |
| io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObserver) { |
| io.grpc.stub.ClientCalls.asyncServerStreamingCall( |
| getChannel().newCall(getStreamingOutputCallMethod(), getCallOptions()), request, 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.compiler.Test.StreamingInputCallRequest> streamingInputCall( |
| io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallResponse> responseObserver) { |
| return io.grpc.stub.ClientCalls.asyncClientStreamingCall( |
| getChannel().newCall(getStreamingInputCallMethod(), getCallOptions()), 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.compiler.Test.StreamingOutputCallRequest> fullBidiCall( |
| io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObserver) { |
| return io.grpc.stub.ClientCalls.asyncBidiStreamingCall( |
| getChannel().newCall(getFullBidiCallMethod(), getCallOptions()), 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.compiler.Test.StreamingOutputCallRequest> halfBidiCall( |
| io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObserver) { |
| return io.grpc.stub.ClientCalls.asyncBidiStreamingCall( |
| getChannel().newCall(getHalfBidiCallMethod(), getCallOptions()), responseObserver); |
| } |
| |
| /** |
| * <pre> |
| * An RPC method whose Java name collides with a keyword, and whose generated |
| * method should have a '_' appended. |
| * </pre> |
| */ |
| public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallRequest> import_( |
| io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallResponse> responseObserver) { |
| return io.grpc.stub.ClientCalls.asyncBidiStreamingCall( |
| getChannel().newCall(getImportMethod(), getCallOptions()), responseObserver); |
| } |
| |
| /** |
| * <pre> |
| * A unary call that is Safe. |
| * </pre> |
| */ |
| public void safeCall(io.grpc.testing.compiler.Test.SimpleRequest request, |
| io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse> responseObserver) { |
| io.grpc.stub.ClientCalls.asyncUnaryCall( |
| getChannel().newCall(getSafeCallMethod(), getCallOptions()), request, responseObserver); |
| } |
| |
| /** |
| * <pre> |
| * A unary call that is Idempotent. |
| * </pre> |
| */ |
| public void idempotentCall(io.grpc.testing.compiler.Test.SimpleRequest request, |
| io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse> responseObserver) { |
| io.grpc.stub.ClientCalls.asyncUnaryCall( |
| getChannel().newCall(getIdempotentCallMethod(), getCallOptions()), request, responseObserver); |
| } |
| } |
| |
| /** |
| * A stub to allow clients to do synchronous rpc calls to service TestService. |
| * <pre> |
| * Test service that supports all call types. |
| * </pre> |
| */ |
| public static final class TestServiceBlockingStub |
| extends io.grpc.stub.AbstractBlockingStub<TestServiceBlockingStub> { |
| 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); |
| } |
| |
| /** |
| * <pre> |
| * One request followed by one response. |
| * The server returns the client payload as-is. |
| * </pre> |
| */ |
| public io.grpc.testing.compiler.Test.SimpleResponse unaryCall(io.grpc.testing.compiler.Test.SimpleRequest request) { |
| return io.grpc.stub.ClientCalls.blockingUnaryCall( |
| getChannel(), getUnaryCallMethod(), getCallOptions(), 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.compiler.Test.StreamingOutputCallResponse> streamingOutputCall( |
| io.grpc.testing.compiler.Test.StreamingOutputCallRequest request) { |
| return io.grpc.stub.ClientCalls.blockingServerStreamingCall( |
| getChannel(), getStreamingOutputCallMethod(), getCallOptions(), request); |
| } |
| |
| /** |
| * <pre> |
| * A unary call that is Safe. |
| * </pre> |
| */ |
| public io.grpc.testing.compiler.Test.SimpleResponse safeCall(io.grpc.testing.compiler.Test.SimpleRequest request) { |
| return io.grpc.stub.ClientCalls.blockingUnaryCall( |
| getChannel(), getSafeCallMethod(), getCallOptions(), request); |
| } |
| |
| /** |
| * <pre> |
| * A unary call that is Idempotent. |
| * </pre> |
| */ |
| public io.grpc.testing.compiler.Test.SimpleResponse idempotentCall(io.grpc.testing.compiler.Test.SimpleRequest request) { |
| return io.grpc.stub.ClientCalls.blockingUnaryCall( |
| getChannel(), getIdempotentCallMethod(), getCallOptions(), request); |
| } |
| } |
| |
| /** |
| * A stub to allow clients to do ListenableFuture-style rpc calls to service TestService. |
| * <pre> |
| * Test service that supports all call types. |
| * </pre> |
| */ |
| public static final class TestServiceFutureStub |
| extends io.grpc.stub.AbstractFutureStub<TestServiceFutureStub> { |
| 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); |
| } |
| |
| /** |
| * <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.compiler.Test.SimpleResponse> unaryCall( |
| io.grpc.testing.compiler.Test.SimpleRequest request) { |
| return io.grpc.stub.ClientCalls.futureUnaryCall( |
| getChannel().newCall(getUnaryCallMethod(), getCallOptions()), request); |
| } |
| |
| /** |
| * <pre> |
| * A unary call that is Safe. |
| * </pre> |
| */ |
| public com.google.common.util.concurrent.ListenableFuture<io.grpc.testing.compiler.Test.SimpleResponse> safeCall( |
| io.grpc.testing.compiler.Test.SimpleRequest request) { |
| return io.grpc.stub.ClientCalls.futureUnaryCall( |
| getChannel().newCall(getSafeCallMethod(), getCallOptions()), request); |
| } |
| |
| /** |
| * <pre> |
| * A unary call that is Idempotent. |
| * </pre> |
| */ |
| public com.google.common.util.concurrent.ListenableFuture<io.grpc.testing.compiler.Test.SimpleResponse> idempotentCall( |
| io.grpc.testing.compiler.Test.SimpleRequest request) { |
| return io.grpc.stub.ClientCalls.futureUnaryCall( |
| getChannel().newCall(getIdempotentCallMethod(), getCallOptions()), request); |
| } |
| } |
| |
| private static final int METHODID_UNARY_CALL = 0; |
| private static final int METHODID_STREAMING_OUTPUT_CALL = 1; |
| private static final int METHODID_SAFE_CALL = 2; |
| private static final int METHODID_IDEMPOTENT_CALL = 3; |
| private static final int METHODID_STREAMING_INPUT_CALL = 4; |
| private static final int METHODID_FULL_BIDI_CALL = 5; |
| private static final int METHODID_HALF_BIDI_CALL = 6; |
| private static final int METHODID_IMPORT = 7; |
| |
| private static final 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 AsyncService serviceImpl; |
| private final int methodId; |
| |
| MethodHandlers(AsyncService 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.compiler.Test.SimpleRequest) request, |
| (io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse>) responseObserver); |
| break; |
| case METHODID_STREAMING_OUTPUT_CALL: |
| serviceImpl.streamingOutputCall((io.grpc.testing.compiler.Test.StreamingOutputCallRequest) request, |
| (io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse>) responseObserver); |
| break; |
| case METHODID_SAFE_CALL: |
| serviceImpl.safeCall((io.grpc.testing.compiler.Test.SimpleRequest) request, |
| (io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse>) responseObserver); |
| break; |
| case METHODID_IDEMPOTENT_CALL: |
| serviceImpl.idempotentCall((io.grpc.testing.compiler.Test.SimpleRequest) request, |
| (io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse>) 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.compiler.Test.StreamingInputCallResponse>) responseObserver); |
| case METHODID_FULL_BIDI_CALL: |
| return (io.grpc.stub.StreamObserver<Req>) serviceImpl.fullBidiCall( |
| (io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse>) responseObserver); |
| case METHODID_HALF_BIDI_CALL: |
| return (io.grpc.stub.StreamObserver<Req>) serviceImpl.halfBidiCall( |
| (io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse>) responseObserver); |
| case METHODID_IMPORT: |
| return (io.grpc.stub.StreamObserver<Req>) serviceImpl.import_( |
| (io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallResponse>) responseObserver); |
| default: |
| throw new AssertionError(); |
| } |
| } |
| } |
| |
| public static final io.grpc.ServerServiceDefinition bindService(AsyncService service) { |
| return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor()) |
| .addMethod( |
| getUnaryCallMethod(), |
| io.grpc.stub.ServerCalls.asyncUnaryCall( |
| new MethodHandlers< |
| io.grpc.testing.compiler.Test.SimpleRequest, |
| io.grpc.testing.compiler.Test.SimpleResponse>( |
| service, METHODID_UNARY_CALL))) |
| .addMethod( |
| getStreamingOutputCallMethod(), |
| io.grpc.stub.ServerCalls.asyncServerStreamingCall( |
| new MethodHandlers< |
| io.grpc.testing.compiler.Test.StreamingOutputCallRequest, |
| io.grpc.testing.compiler.Test.StreamingOutputCallResponse>( |
| service, METHODID_STREAMING_OUTPUT_CALL))) |
| .addMethod( |
| getStreamingInputCallMethod(), |
| io.grpc.stub.ServerCalls.asyncClientStreamingCall( |
| new MethodHandlers< |
| io.grpc.testing.compiler.Test.StreamingInputCallRequest, |
| io.grpc.testing.compiler.Test.StreamingInputCallResponse>( |
| service, METHODID_STREAMING_INPUT_CALL))) |
| .addMethod( |
| getFullBidiCallMethod(), |
| io.grpc.stub.ServerCalls.asyncBidiStreamingCall( |
| new MethodHandlers< |
| io.grpc.testing.compiler.Test.StreamingOutputCallRequest, |
| io.grpc.testing.compiler.Test.StreamingOutputCallResponse>( |
| service, METHODID_FULL_BIDI_CALL))) |
| .addMethod( |
| getHalfBidiCallMethod(), |
| io.grpc.stub.ServerCalls.asyncBidiStreamingCall( |
| new MethodHandlers< |
| io.grpc.testing.compiler.Test.StreamingOutputCallRequest, |
| io.grpc.testing.compiler.Test.StreamingOutputCallResponse>( |
| service, METHODID_HALF_BIDI_CALL))) |
| .addMethod( |
| getImportMethod(), |
| io.grpc.stub.ServerCalls.asyncBidiStreamingCall( |
| new MethodHandlers< |
| io.grpc.testing.compiler.Test.StreamingInputCallRequest, |
| io.grpc.testing.compiler.Test.StreamingInputCallResponse>( |
| service, METHODID_IMPORT))) |
| .addMethod( |
| getSafeCallMethod(), |
| io.grpc.stub.ServerCalls.asyncUnaryCall( |
| new MethodHandlers< |
| io.grpc.testing.compiler.Test.SimpleRequest, |
| io.grpc.testing.compiler.Test.SimpleResponse>( |
| service, METHODID_SAFE_CALL))) |
| .addMethod( |
| getIdempotentCallMethod(), |
| io.grpc.stub.ServerCalls.asyncUnaryCall( |
| new MethodHandlers< |
| io.grpc.testing.compiler.Test.SimpleRequest, |
| io.grpc.testing.compiler.Test.SimpleResponse>( |
| service, METHODID_IDEMPOTENT_CALL))) |
| .build(); |
| } |
| |
| private static volatile io.grpc.ServiceDescriptor serviceDescriptor; |
| |
| public static io.grpc.ServiceDescriptor getServiceDescriptor() { |
| io.grpc.ServiceDescriptor result = serviceDescriptor; |
| if (result == null) { |
| synchronized (TestServiceGrpc.class) { |
| result = serviceDescriptor; |
| if (result == null) { |
| serviceDescriptor = result = io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME) |
| .addMethod(getUnaryCallMethod()) |
| .addMethod(getStreamingOutputCallMethod()) |
| .addMethod(getStreamingInputCallMethod()) |
| .addMethod(getFullBidiCallMethod()) |
| .addMethod(getHalfBidiCallMethod()) |
| .addMethod(getImportMethod()) |
| .addMethod(getSafeCallMethod()) |
| .addMethod(getIdempotentCallMethod()) |
| .build(); |
| } |
| } |
| } |
| return result; |
| } |
| } |
