compiler: add build option to enable deprecated generated code
partially resolving #1469
The added option for java_plugin `enable_deprecated` is `true` by default in `java_plugin.cpp`, so the generated code for `TestService.java` (`compiler/build.gradle` not setting this option) has all deprecated interfaces and static bindService method.
`./build.gradle` and `examples/build.gradle` set this option explicitly to `false`, so all the other generated classes do not have deprecated code.
Will set `enable_deprecated` to `false` by default in future PR when we are ready.
diff --git a/compiler/src/testLite/golden/TestService.java.txt b/compiler/src/testLite/golden/TestService.java.txt
index b81fc9b..7637f07 100644
--- a/compiler/src/testLite/golden/TestService.java.txt
+++ b/compiler/src/testLite/golden/TestService.java.txt
@@ -104,7 +104,7 @@
* Test service that supports all call types.
* </pre>
*/
- @java.lang.Deprecated public static interface TestService {
+ public static abstract class TestServiceImplBase implements io.grpc.BindableService, TestService {
/**
* <pre>
@@ -112,8 +112,11 @@
* The server returns the client payload as-is.
* </pre>
*/
+ @java.lang.Override
public void unaryCall(io.grpc.testing.integration.Test.SimpleRequest request,
- io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.SimpleResponse> responseObserver);
+ io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.SimpleResponse> responseObserver) {
+ asyncUnimplementedUnaryCall(METHOD_UNARY_CALL, responseObserver);
+ }
/**
* <pre>
@@ -121,8 +124,11 @@
* The server returns the payload with client desired type and sizes.
* </pre>
*/
+ @java.lang.Override
public void streamingOutputCall(io.grpc.testing.integration.Test.StreamingOutputCallRequest request,
- io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallResponse> responseObserver);
+ io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallResponse> responseObserver) {
+ asyncUnimplementedUnaryCall(METHOD_STREAMING_OUTPUT_CALL, responseObserver);
+ }
/**
* <pre>
@@ -130,8 +136,11 @@
* The server returns the aggregated size of client payload as the result.
* </pre>
*/
+ @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);
+ io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingInputCallResponse> responseObserver) {
+ return asyncUnimplementedStreamingCall(METHOD_STREAMING_INPUT_CALL, responseObserver);
+ }
/**
* <pre>
@@ -140,8 +149,11 @@
* demonstrates the idea of full bidirectionality.
* </pre>
*/
+ @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);
+ io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallResponse> responseObserver) {
+ return asyncUnimplementedStreamingCall(METHOD_FULL_BIDI_CALL, responseObserver);
+ }
/**
* <pre>
@@ -151,37 +163,6 @@
* 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("https://github.com/grpc/grpc-java/issues/1469")
- public static abstract class TestServiceImplBase 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) {
@@ -189,7 +170,43 @@
}
@java.lang.Override public io.grpc.ServerServiceDefinition bindService() {
- return TestServiceGrpc.bindService(this);
+ return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
+ .addMethod(
+ METHOD_UNARY_CALL,
+ asyncUnaryCall(
+ new MethodHandlers<
+ io.grpc.testing.integration.Test.SimpleRequest,
+ io.grpc.testing.integration.Test.SimpleResponse>(
+ this, METHODID_UNARY_CALL)))
+ .addMethod(
+ METHOD_STREAMING_OUTPUT_CALL,
+ asyncServerStreamingCall(
+ new MethodHandlers<
+ io.grpc.testing.integration.Test.StreamingOutputCallRequest,
+ io.grpc.testing.integration.Test.StreamingOutputCallResponse>(
+ this, METHODID_STREAMING_OUTPUT_CALL)))
+ .addMethod(
+ METHOD_STREAMING_INPUT_CALL,
+ asyncClientStreamingCall(
+ new MethodHandlers<
+ io.grpc.testing.integration.Test.StreamingInputCallRequest,
+ io.grpc.testing.integration.Test.StreamingInputCallResponse>(
+ this, METHODID_STREAMING_INPUT_CALL)))
+ .addMethod(
+ METHOD_FULL_BIDI_CALL,
+ asyncBidiStreamingCall(
+ new MethodHandlers<
+ io.grpc.testing.integration.Test.StreamingOutputCallRequest,
+ io.grpc.testing.integration.Test.StreamingOutputCallResponse>(
+ this, METHODID_FULL_BIDI_CALL)))
+ .addMethod(
+ METHOD_HALF_BIDI_CALL,
+ asyncBidiStreamingCall(
+ new MethodHandlers<
+ io.grpc.testing.integration.Test.StreamingOutputCallRequest,
+ io.grpc.testing.integration.Test.StreamingOutputCallResponse>(
+ this, METHODID_HALF_BIDI_CALL)))
+ .build();
}
}
@@ -198,43 +215,6 @@
* Test service that supports all call types.
* </pre>
*/
- @java.lang.Deprecated 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>
- */
- @java.lang.Deprecated 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) {
@@ -252,6 +232,12 @@
return new TestServiceStub(channel, callOptions);
}
+ /**
+ * <pre>
+ * One request followed by one response.
+ * The server returns the client payload as-is.
+ * </pre>
+ */
@java.lang.Override
public void unaryCall(io.grpc.testing.integration.Test.SimpleRequest request,
io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.SimpleResponse> responseObserver) {
@@ -259,6 +245,12 @@
getChannel().newCall(METHOD_UNARY_CALL, 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>
+ */
@java.lang.Override
public void streamingOutputCall(io.grpc.testing.integration.Test.StreamingOutputCallRequest request,
io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallResponse> responseObserver) {
@@ -266,6 +258,12 @@
getChannel().newCall(METHOD_STREAMING_OUTPUT_CALL, 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>
+ */
@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) {
@@ -273,6 +271,13 @@
getChannel().newCall(METHOD_STREAMING_INPUT_CALL, 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>
+ */
@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) {
@@ -280,6 +285,14 @@
getChannel().newCall(METHOD_FULL_BIDI_CALL, 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>
+ */
@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) {
@@ -288,6 +301,11 @@
}
}
+ /**
+ * <pre>
+ * Test service that supports all call types.
+ * </pre>
+ */
public static class TestServiceBlockingStub extends io.grpc.stub.AbstractStub<TestServiceBlockingStub>
implements TestServiceBlockingClient {
private TestServiceBlockingStub(io.grpc.Channel channel) {
@@ -305,12 +323,24 @@
return new TestServiceBlockingStub(channel, callOptions);
}
+ /**
+ * <pre>
+ * One request followed by one response.
+ * The server returns the client payload as-is.
+ * </pre>
+ */
@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);
}
+ /**
+ * <pre>
+ * One request followed by a sequence of responses (streamed download).
+ * The server returns the payload with client desired type and sizes.
+ * </pre>
+ */
@java.lang.Override
public java.util.Iterator<io.grpc.testing.integration.Test.StreamingOutputCallResponse> streamingOutputCall(
io.grpc.testing.integration.Test.StreamingOutputCallRequest request) {
@@ -319,6 +349,11 @@
}
}
+ /**
+ * <pre>
+ * Test service that supports all call types.
+ * </pre>
+ */
public static class TestServiceFutureStub extends io.grpc.stub.AbstractStub<TestServiceFutureStub>
implements TestServiceFutureClient {
private TestServiceFutureStub(io.grpc.Channel channel) {
@@ -336,6 +371,12 @@
return new TestServiceFutureStub(channel, callOptions);
}
+ /**
+ * <pre>
+ * One request followed by one response.
+ * The server returns the client payload as-is.
+ * </pre>
+ */
@java.lang.Override
public com.google.common.util.concurrent.ListenableFuture<io.grpc.testing.integration.Test.SimpleResponse> unaryCall(
io.grpc.testing.integration.Test.SimpleRequest request) {
@@ -344,8 +385,165 @@
}
}
+ /**
+ * This will be removed in the next release.
+ * If your code has been using gRPC-java v0.15.0 or higher already,
+ * the following changes to your code are suggested:
+ * <ul>
+ * <li> replace {@code extends/implements TestService} with {@code extends TestServiceImplBase} for server side;</li>
+ * <li> replace {@code TestService} with {@code TestServiceStub} for client side;</li>
+ * <li> replace usage of {@code TestService} with {@code TestServiceImplBase};</li>
+ * <li> replace usage of {@code AbstractTestService} with {@link TestServiceImplBase};</li>
+ * <li> replace {@code serverBuilder.addService(TestServiceGrpc.bindService(serviceImpl))}
+ * with {@code serverBuilder.addService(serviceImpl)};</li>
+ * <li> if you are mocking stubs using mockito, please do not mock them.
+ * See the documentation on testing with gRPC-java;</li>
+ * <li> replace {@code TestServiceBlockingClient} with {@link TestServiceBlockingStub};</li>
+ * <li> replace {@code TestServiceFutureClient} with {@link TestServiceFutureStub}.</li>
+ * </ul>
+ */
+ @java.lang.Deprecated public static interface TestService {
+
+ public void unaryCall(io.grpc.testing.integration.Test.SimpleRequest request,
+ io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.SimpleResponse> responseObserver);
+
+ public void streamingOutputCall(io.grpc.testing.integration.Test.StreamingOutputCallRequest request,
+ io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallResponse> responseObserver);
+
+ public io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingInputCallRequest> streamingInputCall(
+ io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingInputCallResponse> responseObserver);
+
+ public io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallRequest> fullBidiCall(
+ io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallResponse> responseObserver);
+
+ public io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallRequest> halfBidiCall(
+ io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallResponse> responseObserver);
+ }
+
+ /**
+ * This will be removed in the next release.
+ * If your code has been using gRPC-java v0.15.0 or higher already,
+ * the following changes to your code are suggested:
+ * <ul>
+ * <li> replace {@code extends/implements TestService} with {@code extends TestServiceImplBase} for server side;</li>
+ * <li> replace {@code TestService} with {@code TestServiceStub} for client side;</li>
+ * <li> replace usage of {@code TestService} with {@code TestServiceImplBase};</li>
+ * <li> replace usage of {@code AbstractTestService} with {@link TestServiceImplBase};</li>
+ * <li> replace {@code serverBuilder.addService(TestServiceGrpc.bindService(serviceImpl))}
+ * with {@code serverBuilder.addService(serviceImpl)};</li>
+ * <li> if you are mocking stubs using mockito, please do not mock them.
+ * See the documentation on testing with gRPC-java;</li>
+ * <li> replace {@code TestServiceBlockingClient} with {@link TestServiceBlockingStub};</li>
+ * <li> replace {@code TestServiceFutureClient} with {@link TestServiceFutureStub}.</li>
+ * </ul>
+ */
+ @java.lang.Deprecated public static interface TestServiceBlockingClient {
+
+ public io.grpc.testing.integration.Test.SimpleResponse unaryCall(io.grpc.testing.integration.Test.SimpleRequest request);
+
+ public java.util.Iterator<io.grpc.testing.integration.Test.StreamingOutputCallResponse> streamingOutputCall(
+ io.grpc.testing.integration.Test.StreamingOutputCallRequest request);
+ }
+
+ /**
+ * This will be removed in the next release.
+ * If your code has been using gRPC-java v0.15.0 or higher already,
+ * the following changes to your code are suggested:
+ * <ul>
+ * <li> replace {@code extends/implements TestService} with {@code extends TestServiceImplBase} for server side;</li>
+ * <li> replace {@code TestService} with {@code TestServiceStub} for client side;</li>
+ * <li> replace usage of {@code TestService} with {@code TestServiceImplBase};</li>
+ * <li> replace usage of {@code AbstractTestService} with {@link TestServiceImplBase};</li>
+ * <li> replace {@code serverBuilder.addService(TestServiceGrpc.bindService(serviceImpl))}
+ * with {@code serverBuilder.addService(serviceImpl)};</li>
+ * <li> if you are mocking stubs using mockito, please do not mock them.
+ * See the documentation on testing with gRPC-java;</li>
+ * <li> replace {@code TestServiceBlockingClient} with {@link TestServiceBlockingStub};</li>
+ * <li> replace {@code TestServiceFutureClient} with {@link TestServiceFutureStub}.</li>
+ * </ul>
+ */
+ @java.lang.Deprecated public static interface TestServiceFutureClient {
+
+ public com.google.common.util.concurrent.ListenableFuture<io.grpc.testing.integration.Test.SimpleResponse> unaryCall(
+ io.grpc.testing.integration.Test.SimpleRequest request);
+ }
+
+ /**
+ * This will be removed in the next release.
+ * If your code has been using gRPC-java v0.15.0 or higher already,
+ * the following changes to your code are suggested:
+ * <ul>
+ * <li> replace {@code extends/implements TestService} with {@code extends TestServiceImplBase} for server side;</li>
+ * <li> replace {@code TestService} with {@code TestServiceStub} for client side;</li>
+ * <li> replace usage of {@code TestService} with {@code TestServiceImplBase};</li>
+ * <li> replace usage of {@code AbstractTestService} with {@link TestServiceImplBase};</li>
+ * <li> replace {@code serverBuilder.addService(TestServiceGrpc.bindService(serviceImpl))}
+ * with {@code serverBuilder.addService(serviceImpl)};</li>
+ * <li> if you are mocking stubs using mockito, please do not mock them.
+ * See the documentation on testing with gRPC-java;</li>
+ * <li> replace {@code TestServiceBlockingClient} with {@link TestServiceBlockingStub};</li>
+ * <li> replace {@code TestServiceFutureClient} with {@link TestServiceFutureStub}.</li>
+ * </ul>
+ */
@java.lang.Deprecated public static abstract class AbstractTestService extends TestServiceImplBase {}
+ /**
+ * This will be removed in the next release.
+ * If your code has been using gRPC-java v0.15.0 or higher already,
+ * the following changes to your code are suggested:
+ * <ul>
+ * <li> replace {@code extends/implements TestService} with {@code extends TestServiceImplBase} for server side;</li>
+ * <li> replace {@code TestService} with {@code TestServiceStub} for client side;</li>
+ * <li> replace usage of {@code TestService} with {@code TestServiceImplBase};</li>
+ * <li> replace usage of {@code AbstractTestService} with {@link TestServiceImplBase};</li>
+ * <li> replace {@code serverBuilder.addService(TestServiceGrpc.bindService(serviceImpl))}
+ * with {@code serverBuilder.addService(serviceImpl)};</li>
+ * <li> if you are mocking stubs using mockito, please do not mock them.
+ * See the documentation on testing with gRPC-java;</li>
+ * <li> replace {@code TestServiceBlockingClient} with {@link TestServiceBlockingStub};</li>
+ * <li> replace {@code TestServiceFutureClient} with {@link TestServiceFutureStub}.</li>
+ * </ul>
+ */
+ @java.lang.Deprecated public static io.grpc.ServerServiceDefinition bindService(final TestService serviceImpl) {
+ return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
+ .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();
+ }
+
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;
@@ -411,44 +609,4 @@
METHOD_HALF_BIDI_CALL);
}
- @java.lang.Deprecated public static io.grpc.ServerServiceDefinition bindService(
- final TestService serviceImpl) {
- return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
- .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();
- }
}