grpc
/
grpc-java
mirror of https://github.com/grpc/grpc-java.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

compiler: make testing service used by compiler not conflict with interop-testing proto 

This change puts the compiler test.proto file in a directory that matches it's path.  The current proto package has a namespace collision with the grpc.testing proto in interop-testing.  Thus, this PR:

* change the package of test.proto to be grpc.testing.compiler
* moves the test.proto into the matching grpc/testing/compiler/test.proto path
* updates the generated code.
This commit is contained in:
Carl Mastrangelo 2018-05-01 10:13:18 -07:00 committed by GitHub
parent d35e77869e
commit 8be87de9b0
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
5 changed files with 433 additions and 418 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
compiler/build.gradle
View File

@ -326,7 +326,7 @@ def configureTestTask(Task task, String dep, String extraPackage) {
} }
// File isn't found on Windows if last slash is forward-slash // File isn't found on Windows if last slash is forward-slash
def slash = System.getProperty("file.separator") def slash = System.getProperty("file.separator")
task.args "$buildDir/generated/source/proto/test${dep}/grpc/io/grpc/testing/integration${extraPackage}${slash}TestServiceGrpc.java", task.args "$buildDir/generated/source/proto/test${dep}/grpc/io/grpc/testing/compiler${extraPackage}${slash}TestServiceGrpc.java",
"$projectDir/src/test${dep}/golden/TestService.java.txt" "$projectDir/src/test${dep}/golden/TestService.java.txt"
} }

262
compiler/src/test/golden/TestService.java.txt
View File

@ -1,4 +1,4 @@
package io.grpc.testing.integration; package io.grpc.testing.compiler;
import static io.grpc.MethodDescriptor.generateFullMethodName; import static io.grpc.MethodDescriptor.generateFullMethodName;
import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall; import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
@ -22,44 +22,44 @@ import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
*/ */
@javax.annotation.Generated( @javax.annotation.Generated(
value = "by gRPC proto compiler (version 1.13.0-SNAPSHOT)", value = "by gRPC proto compiler (version 1.13.0-SNAPSHOT)",
comments = "Source: test.proto") comments = "Source: grpc/testing/compiler/test.proto")
public final class TestServiceGrpc { public final class TestServiceGrpc {
private TestServiceGrpc() {} private TestServiceGrpc() {}
public static final String SERVICE_NAME = "grpc.testing.TestService"; public static final String SERVICE_NAME = "grpc.testing.compiler.TestService";
// Static method descriptors that strictly reflect the proto. // Static method descriptors that strictly reflect the proto.
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
@java.lang.Deprecated // Use {@link #getUnaryCallMethod()} instead. @java.lang.Deprecated // Use {@link #getUnaryCallMethod()} instead.
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.SimpleRequest, public static final io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest,
io.grpc.testing.integration.Test.SimpleResponse> METHOD_UNARY_CALL = getUnaryCallMethodHelper(); io.grpc.testing.compiler.Test.SimpleResponse> METHOD_UNARY_CALL = getUnaryCallMethodHelper();
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.SimpleRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest,
io.grpc.testing.integration.Test.SimpleResponse> getUnaryCallMethod; io.grpc.testing.compiler.Test.SimpleResponse> getUnaryCallMethod;
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
public static io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.SimpleRequest, public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest,
io.grpc.testing.integration.Test.SimpleResponse> getUnaryCallMethod() { io.grpc.testing.compiler.Test.SimpleResponse> getUnaryCallMethod() {
return getUnaryCallMethodHelper(); return getUnaryCallMethodHelper();
} }
private static io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.SimpleRequest, private static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest,
io.grpc.testing.integration.Test.SimpleResponse> getUnaryCallMethodHelper() { io.grpc.testing.compiler.Test.SimpleResponse> getUnaryCallMethodHelper() {
io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.SimpleRequest, io.grpc.testing.integration.Test.SimpleResponse> getUnaryCallMethod; io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Test.SimpleResponse> getUnaryCallMethod;
if ((getUnaryCallMethod = TestServiceGrpc.getUnaryCallMethod) == null) { if ((getUnaryCallMethod = TestServiceGrpc.getUnaryCallMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getUnaryCallMethod = TestServiceGrpc.getUnaryCallMethod) == null) { if ((getUnaryCallMethod = TestServiceGrpc.getUnaryCallMethod) == null) {
TestServiceGrpc.getUnaryCallMethod = getUnaryCallMethod = TestServiceGrpc.getUnaryCallMethod = getUnaryCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Test.SimpleRequest, io.grpc.testing.integration.Test.SimpleResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Test.SimpleResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(
"grpc.testing.TestService", "UnaryCall")) "grpc.testing.compiler.TestService", "UnaryCall"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.Test.SimpleRequest.getDefaultInstance())) io.grpc.testing.compiler.Test.SimpleRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.Test.SimpleResponse.getDefaultInstance())) io.grpc.testing.compiler.Test.SimpleResponse.getDefaultInstance()))
.setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("UnaryCall")) .setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("UnaryCall"))
.build(); .build();
} }
@ -69,34 +69,34 @@ public final class TestServiceGrpc {
} }
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
@java.lang.Deprecated // Use {@link #getStreamingOutputCallMethod()} instead. @java.lang.Deprecated // Use {@link #getStreamingOutputCallMethod()} instead.
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest, public static final io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.Test.StreamingOutputCallResponse> METHOD_STREAMING_OUTPUT_CALL = getStreamingOutputCallMethodHelper(); io.grpc.testing.compiler.Test.StreamingOutputCallResponse> METHOD_STREAMING_OUTPUT_CALL = getStreamingOutputCallMethodHelper();
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod; io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod;
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
public static io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest, public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod() { io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod() {
return getStreamingOutputCallMethodHelper(); return getStreamingOutputCallMethodHelper();
} }
private static io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest, private static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.Test.StreamingOutputCallResponse> getStreamingOutputCallMethodHelper() { io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getStreamingOutputCallMethodHelper() {
io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest, io.grpc.testing.integration.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod; io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod;
if ((getStreamingOutputCallMethod = TestServiceGrpc.getStreamingOutputCallMethod) == null) { if ((getStreamingOutputCallMethod = TestServiceGrpc.getStreamingOutputCallMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getStreamingOutputCallMethod = TestServiceGrpc.getStreamingOutputCallMethod) == null) { if ((getStreamingOutputCallMethod = TestServiceGrpc.getStreamingOutputCallMethod) == null) {
TestServiceGrpc.getStreamingOutputCallMethod = getStreamingOutputCallMethod = TestServiceGrpc.getStreamingOutputCallMethod = getStreamingOutputCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Test.StreamingOutputCallRequest, io.grpc.testing.integration.Test.StreamingOutputCallResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(
"grpc.testing.TestService", "StreamingOutputCall")) "grpc.testing.compiler.TestService", "StreamingOutputCall"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.Test.StreamingOutputCallRequest.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingOutputCallRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.Test.StreamingOutputCallResponse.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingOutputCallResponse.getDefaultInstance()))
.setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("StreamingOutputCall")) .setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("StreamingOutputCall"))
.build(); .build();
} }
@ -106,34 +106,34 @@ public final class TestServiceGrpc {
} }
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
@java.lang.Deprecated // Use {@link #getStreamingInputCallMethod()} instead. @java.lang.Deprecated // Use {@link #getStreamingInputCallMethod()} instead.
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingInputCallRequest, public static final io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
io.grpc.testing.integration.Test.StreamingInputCallResponse> METHOD_STREAMING_INPUT_CALL = getStreamingInputCallMethodHelper(); io.grpc.testing.compiler.Test.StreamingInputCallResponse> METHOD_STREAMING_INPUT_CALL = getStreamingInputCallMethodHelper();
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingInputCallRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
io.grpc.testing.integration.Test.StreamingInputCallResponse> getStreamingInputCallMethod; io.grpc.testing.compiler.Test.StreamingInputCallResponse> getStreamingInputCallMethod;
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
public static io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingInputCallRequest, public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
io.grpc.testing.integration.Test.StreamingInputCallResponse> getStreamingInputCallMethod() { io.grpc.testing.compiler.Test.StreamingInputCallResponse> getStreamingInputCallMethod() {
return getStreamingInputCallMethodHelper(); return getStreamingInputCallMethodHelper();
} }
private static io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingInputCallRequest, private static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
io.grpc.testing.integration.Test.StreamingInputCallResponse> getStreamingInputCallMethodHelper() { io.grpc.testing.compiler.Test.StreamingInputCallResponse> getStreamingInputCallMethodHelper() {
io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingInputCallRequest, io.grpc.testing.integration.Test.StreamingInputCallResponse> getStreamingInputCallMethod; io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest, io.grpc.testing.compiler.Test.StreamingInputCallResponse> getStreamingInputCallMethod;
if ((getStreamingInputCallMethod = TestServiceGrpc.getStreamingInputCallMethod) == null) { if ((getStreamingInputCallMethod = TestServiceGrpc.getStreamingInputCallMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getStreamingInputCallMethod = TestServiceGrpc.getStreamingInputCallMethod) == null) { if ((getStreamingInputCallMethod = TestServiceGrpc.getStreamingInputCallMethod) == null) {
TestServiceGrpc.getStreamingInputCallMethod = getStreamingInputCallMethod = TestServiceGrpc.getStreamingInputCallMethod = getStreamingInputCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Test.StreamingInputCallRequest, io.grpc.testing.integration.Test.StreamingInputCallResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingInputCallRequest, io.grpc.testing.compiler.Test.StreamingInputCallResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(
"grpc.testing.TestService", "StreamingInputCall")) "grpc.testing.compiler.TestService", "StreamingInputCall"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.Test.StreamingInputCallRequest.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingInputCallRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.Test.StreamingInputCallResponse.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingInputCallResponse.getDefaultInstance()))
.setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("StreamingInputCall")) .setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("StreamingInputCall"))
.build(); .build();
} }
@ -143,34 +143,34 @@ public final class TestServiceGrpc {
} }
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
@java.lang.Deprecated // Use {@link #getFullBidiCallMethod()} instead. @java.lang.Deprecated // Use {@link #getFullBidiCallMethod()} instead.
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest, public static final io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.Test.StreamingOutputCallResponse> METHOD_FULL_BIDI_CALL = getFullBidiCallMethodHelper(); io.grpc.testing.compiler.Test.StreamingOutputCallResponse> METHOD_FULL_BIDI_CALL = getFullBidiCallMethodHelper();
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.Test.StreamingOutputCallResponse> getFullBidiCallMethod; io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getFullBidiCallMethod;
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
public static io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest, public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.Test.StreamingOutputCallResponse> getFullBidiCallMethod() { io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getFullBidiCallMethod() {
return getFullBidiCallMethodHelper(); return getFullBidiCallMethodHelper();
} }
private static io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest, private static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.Test.StreamingOutputCallResponse> getFullBidiCallMethodHelper() { io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getFullBidiCallMethodHelper() {
io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest, io.grpc.testing.integration.Test.StreamingOutputCallResponse> getFullBidiCallMethod; io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getFullBidiCallMethod;
if ((getFullBidiCallMethod = TestServiceGrpc.getFullBidiCallMethod) == null) { if ((getFullBidiCallMethod = TestServiceGrpc.getFullBidiCallMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getFullBidiCallMethod = TestServiceGrpc.getFullBidiCallMethod) == null) { if ((getFullBidiCallMethod = TestServiceGrpc.getFullBidiCallMethod) == null) {
TestServiceGrpc.getFullBidiCallMethod = getFullBidiCallMethod = TestServiceGrpc.getFullBidiCallMethod = getFullBidiCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Test.StreamingOutputCallRequest, io.grpc.testing.integration.Test.StreamingOutputCallResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(
"grpc.testing.TestService", "FullBidiCall")) "grpc.testing.compiler.TestService", "FullBidiCall"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.Test.StreamingOutputCallRequest.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingOutputCallRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.Test.StreamingOutputCallResponse.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingOutputCallResponse.getDefaultInstance()))
.setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("FullBidiCall")) .setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("FullBidiCall"))
.build(); .build();
} }
@ -180,34 +180,34 @@ public final class TestServiceGrpc {
} }
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
@java.lang.Deprecated // Use {@link #getHalfBidiCallMethod()} instead. @java.lang.Deprecated // Use {@link #getHalfBidiCallMethod()} instead.
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest, public static final io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.Test.StreamingOutputCallResponse> METHOD_HALF_BIDI_CALL = getHalfBidiCallMethodHelper(); io.grpc.testing.compiler.Test.StreamingOutputCallResponse> METHOD_HALF_BIDI_CALL = getHalfBidiCallMethodHelper();
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.Test.StreamingOutputCallResponse> getHalfBidiCallMethod; io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getHalfBidiCallMethod;
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
public static io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest, public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.Test.StreamingOutputCallResponse> getHalfBidiCallMethod() { io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getHalfBidiCallMethod() {
return getHalfBidiCallMethodHelper(); return getHalfBidiCallMethodHelper();
} }
private static io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest, private static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.Test.StreamingOutputCallResponse> getHalfBidiCallMethodHelper() { io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getHalfBidiCallMethodHelper() {
io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest, io.grpc.testing.integration.Test.StreamingOutputCallResponse> getHalfBidiCallMethod; io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getHalfBidiCallMethod;
if ((getHalfBidiCallMethod = TestServiceGrpc.getHalfBidiCallMethod) == null) { if ((getHalfBidiCallMethod = TestServiceGrpc.getHalfBidiCallMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getHalfBidiCallMethod = TestServiceGrpc.getHalfBidiCallMethod) == null) { if ((getHalfBidiCallMethod = TestServiceGrpc.getHalfBidiCallMethod) == null) {
TestServiceGrpc.getHalfBidiCallMethod = getHalfBidiCallMethod = TestServiceGrpc.getHalfBidiCallMethod = getHalfBidiCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Test.StreamingOutputCallRequest, io.grpc.testing.integration.Test.StreamingOutputCallResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(
"grpc.testing.TestService", "HalfBidiCall")) "grpc.testing.compiler.TestService", "HalfBidiCall"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.Test.StreamingOutputCallRequest.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingOutputCallRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.Test.StreamingOutputCallResponse.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingOutputCallResponse.getDefaultInstance()))
.setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("HalfBidiCall")) .setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("HalfBidiCall"))
.build(); .build();
} }
@ -217,34 +217,34 @@ public final class TestServiceGrpc {
} }
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
@java.lang.Deprecated // Use {@link #getImportMethod()} instead. @java.lang.Deprecated // Use {@link #getImportMethod()} instead.
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingInputCallRequest, public static final io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
io.grpc.testing.integration.Test.StreamingInputCallResponse> METHOD_IMPORT = getImportMethodHelper(); io.grpc.testing.compiler.Test.StreamingInputCallResponse> METHOD_IMPORT = getImportMethodHelper();
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingInputCallRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
io.grpc.testing.integration.Test.StreamingInputCallResponse> getImportMethod; io.grpc.testing.compiler.Test.StreamingInputCallResponse> getImportMethod;
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
public static io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingInputCallRequest, public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
io.grpc.testing.integration.Test.StreamingInputCallResponse> getImportMethod() { io.grpc.testing.compiler.Test.StreamingInputCallResponse> getImportMethod() {
return getImportMethodHelper(); return getImportMethodHelper();
} }
private static io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingInputCallRequest, private static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
io.grpc.testing.integration.Test.StreamingInputCallResponse> getImportMethodHelper() { io.grpc.testing.compiler.Test.StreamingInputCallResponse> getImportMethodHelper() {
io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingInputCallRequest, io.grpc.testing.integration.Test.StreamingInputCallResponse> getImportMethod; io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest, io.grpc.testing.compiler.Test.StreamingInputCallResponse> getImportMethod;
if ((getImportMethod = TestServiceGrpc.getImportMethod) == null) { if ((getImportMethod = TestServiceGrpc.getImportMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getImportMethod = TestServiceGrpc.getImportMethod) == null) { if ((getImportMethod = TestServiceGrpc.getImportMethod) == null) {
TestServiceGrpc.getImportMethod = getImportMethod = TestServiceGrpc.getImportMethod = getImportMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Test.StreamingInputCallRequest, io.grpc.testing.integration.Test.StreamingInputCallResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingInputCallRequest, io.grpc.testing.compiler.Test.StreamingInputCallResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(
"grpc.testing.TestService", "Import")) "grpc.testing.compiler.TestService", "Import"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.Test.StreamingInputCallRequest.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingInputCallRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.Test.StreamingInputCallResponse.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingInputCallResponse.getDefaultInstance()))
.setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("Import")) .setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("Import"))
.build(); .build();
} }
@ -289,8 +289,8 @@ public final class TestServiceGrpc {
* The server returns the client payload as-is. * The server returns the client payload as-is.
* </pre> * </pre>
*/ */
public void unaryCall(io.grpc.testing.integration.Test.SimpleRequest request, public void unaryCall(io.grpc.testing.compiler.Test.SimpleRequest request,
io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.SimpleResponse> responseObserver) { io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse> responseObserver) {
asyncUnimplementedUnaryCall(getUnaryCallMethodHelper(), responseObserver); asyncUnimplementedUnaryCall(getUnaryCallMethodHelper(), responseObserver);
} }
@ -300,8 +300,8 @@ public final class TestServiceGrpc {
* The server returns the payload with client desired type and sizes. * The server returns the payload with client desired type and sizes.
* </pre> * </pre>
*/ */
public void streamingOutputCall(io.grpc.testing.integration.Test.StreamingOutputCallRequest request, public void streamingOutputCall(io.grpc.testing.compiler.Test.StreamingOutputCallRequest request,
io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallResponse> responseObserver) { io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObserver) {
asyncUnimplementedUnaryCall(getStreamingOutputCallMethodHelper(), responseObserver); asyncUnimplementedUnaryCall(getStreamingOutputCallMethodHelper(), responseObserver);
} }
@ -311,8 +311,8 @@ public final class TestServiceGrpc {
* The server returns the aggregated size of client payload as the result. * The server returns the aggregated size of client payload as the result.
* </pre> * </pre>
*/ */
public io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingInputCallRequest> streamingInputCall( public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallRequest> streamingInputCall(
io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingInputCallResponse> responseObserver) { io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallResponse> responseObserver) {
return asyncUnimplementedStreamingCall(getStreamingInputCallMethodHelper(), responseObserver); return asyncUnimplementedStreamingCall(getStreamingInputCallMethodHelper(), responseObserver);
} }
@ -323,8 +323,8 @@ public final class TestServiceGrpc {
* demonstrates the idea of full bidirectionality. * demonstrates the idea of full bidirectionality.
* </pre> * </pre>
*/ */
public io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallRequest> fullBidiCall( public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallRequest> fullBidiCall(
io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallResponse> responseObserver) { io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObserver) {
return asyncUnimplementedStreamingCall(getFullBidiCallMethodHelper(), responseObserver); return asyncUnimplementedStreamingCall(getFullBidiCallMethodHelper(), responseObserver);
} }
@ -336,8 +336,8 @@ public final class TestServiceGrpc {
* first request. * first request.
* </pre> * </pre>
*/ */
public io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallRequest> halfBidiCall( public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallRequest> halfBidiCall(
io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallResponse> responseObserver) { io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObserver) {
return asyncUnimplementedStreamingCall(getHalfBidiCallMethodHelper(), responseObserver); return asyncUnimplementedStreamingCall(getHalfBidiCallMethodHelper(), responseObserver);
} }
@ -347,8 +347,8 @@ public final class TestServiceGrpc {
* method should have a '_' appended. * method should have a '_' appended.
* </pre> * </pre>
*/ */
public io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingInputCallRequest> import_( public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallRequest> import_(
io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingInputCallResponse> responseObserver) { io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallResponse> responseObserver) {
return asyncUnimplementedStreamingCall(getImportMethodHelper(), responseObserver); return asyncUnimplementedStreamingCall(getImportMethodHelper(), responseObserver);
} }
@ -358,43 +358,43 @@ public final class TestServiceGrpc {
getUnaryCallMethodHelper(), getUnaryCallMethodHelper(),
asyncUnaryCall( asyncUnaryCall(
new MethodHandlers< new MethodHandlers<
io.grpc.testing.integration.Test.SimpleRequest, io.grpc.testing.compiler.Test.SimpleRequest,
io.grpc.testing.integration.Test.SimpleResponse>( io.grpc.testing.compiler.Test.SimpleResponse>(
this, METHODID_UNARY_CALL))) this, METHODID_UNARY_CALL)))
.addMethod( .addMethod(
getStreamingOutputCallMethodHelper(), getStreamingOutputCallMethodHelper(),
asyncServerStreamingCall( asyncServerStreamingCall(
new MethodHandlers< new MethodHandlers<
io.grpc.testing.integration.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.Test.StreamingOutputCallResponse>( io.grpc.testing.compiler.Test.StreamingOutputCallResponse>(
this, METHODID_STREAMING_OUTPUT_CALL))) this, METHODID_STREAMING_OUTPUT_CALL)))
.addMethod( .addMethod(
getStreamingInputCallMethodHelper(), getStreamingInputCallMethodHelper(),
asyncClientStreamingCall( asyncClientStreamingCall(
new MethodHandlers< new MethodHandlers<
io.grpc.testing.integration.Test.StreamingInputCallRequest, io.grpc.testing.compiler.Test.StreamingInputCallRequest,
io.grpc.testing.integration.Test.StreamingInputCallResponse>( io.grpc.testing.compiler.Test.StreamingInputCallResponse>(
this, METHODID_STREAMING_INPUT_CALL))) this, METHODID_STREAMING_INPUT_CALL)))
.addMethod( .addMethod(
getFullBidiCallMethodHelper(), getFullBidiCallMethodHelper(),
asyncBidiStreamingCall( asyncBidiStreamingCall(
new MethodHandlers< new MethodHandlers<
io.grpc.testing.integration.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.Test.StreamingOutputCallResponse>( io.grpc.testing.compiler.Test.StreamingOutputCallResponse>(
this, METHODID_FULL_BIDI_CALL))) this, METHODID_FULL_BIDI_CALL)))
.addMethod( .addMethod(
getHalfBidiCallMethodHelper(), getHalfBidiCallMethodHelper(),
asyncBidiStreamingCall( asyncBidiStreamingCall(
new MethodHandlers< new MethodHandlers<
io.grpc.testing.integration.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.Test.StreamingOutputCallResponse>( io.grpc.testing.compiler.Test.StreamingOutputCallResponse>(
this, METHODID_HALF_BIDI_CALL))) this, METHODID_HALF_BIDI_CALL)))
.addMethod( .addMethod(
getImportMethodHelper(), getImportMethodHelper(),
asyncBidiStreamingCall( asyncBidiStreamingCall(
new MethodHandlers< new MethodHandlers<
io.grpc.testing.integration.Test.StreamingInputCallRequest, io.grpc.testing.compiler.Test.StreamingInputCallRequest,
io.grpc.testing.integration.Test.StreamingInputCallResponse>( io.grpc.testing.compiler.Test.StreamingInputCallResponse>(
this, METHODID_IMPORT))) this, METHODID_IMPORT)))
.build(); .build();
} }
@ -427,8 +427,8 @@ public final class TestServiceGrpc {
* The server returns the client payload as-is. * The server returns the client payload as-is.
* </pre> * </pre>
*/ */
public void unaryCall(io.grpc.testing.integration.Test.SimpleRequest request, public void unaryCall(io.grpc.testing.compiler.Test.SimpleRequest request,
io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.SimpleResponse> responseObserver) { io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse> responseObserver) {
asyncUnaryCall( asyncUnaryCall(
getChannel().newCall(getUnaryCallMethodHelper(), getCallOptions()), request, responseObserver); getChannel().newCall(getUnaryCallMethodHelper(), getCallOptions()), request, responseObserver);
} }
@ -439,8 +439,8 @@ public final class TestServiceGrpc {
* The server returns the payload with client desired type and sizes. * The server returns the payload with client desired type and sizes.
* </pre> * </pre>
*/ */
public void streamingOutputCall(io.grpc.testing.integration.Test.StreamingOutputCallRequest request, public void streamingOutputCall(io.grpc.testing.compiler.Test.StreamingOutputCallRequest request,
io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallResponse> responseObserver) { io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObserver) {
asyncServerStreamingCall( asyncServerStreamingCall(
getChannel().newCall(getStreamingOutputCallMethodHelper(), getCallOptions()), request, responseObserver); getChannel().newCall(getStreamingOutputCallMethodHelper(), getCallOptions()), request, responseObserver);
} }
@ -451,8 +451,8 @@ public final class TestServiceGrpc {
* The server returns the aggregated size of client payload as the result. * The server returns the aggregated size of client payload as the result.
* </pre> * </pre>
*/ */
public io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingInputCallRequest> streamingInputCall( public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallRequest> streamingInputCall(
io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingInputCallResponse> responseObserver) { io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallResponse> responseObserver) {
return asyncClientStreamingCall( return asyncClientStreamingCall(
getChannel().newCall(getStreamingInputCallMethodHelper(), getCallOptions()), responseObserver); getChannel().newCall(getStreamingInputCallMethodHelper(), getCallOptions()), responseObserver);
} }
@ -464,8 +464,8 @@ public final class TestServiceGrpc {
* demonstrates the idea of full bidirectionality. * demonstrates the idea of full bidirectionality.
* </pre> * </pre>
*/ */
public io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallRequest> fullBidiCall( public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallRequest> fullBidiCall(
io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallResponse> responseObserver) { io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObserver) {
return asyncBidiStreamingCall( return asyncBidiStreamingCall(
getChannel().newCall(getFullBidiCallMethodHelper(), getCallOptions()), responseObserver); getChannel().newCall(getFullBidiCallMethodHelper(), getCallOptions()), responseObserver);
} }
@ -478,8 +478,8 @@ public final class TestServiceGrpc {
* first request. * first request.
* </pre> * </pre>
*/ */
public io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallRequest> halfBidiCall( public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallRequest> halfBidiCall(
io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallResponse> responseObserver) { io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObserver) {
return asyncBidiStreamingCall( return asyncBidiStreamingCall(
getChannel().newCall(getHalfBidiCallMethodHelper(), getCallOptions()), responseObserver); getChannel().newCall(getHalfBidiCallMethodHelper(), getCallOptions()), responseObserver);
} }
@ -490,8 +490,8 @@ public final class TestServiceGrpc {
* method should have a '_' appended. * method should have a '_' appended.
* </pre> * </pre>
*/ */
public io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingInputCallRequest> import_( public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallRequest> import_(
io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingInputCallResponse> responseObserver) { io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallResponse> responseObserver) {
return asyncBidiStreamingCall( return asyncBidiStreamingCall(
getChannel().newCall(getImportMethodHelper(), getCallOptions()), responseObserver); getChannel().newCall(getImportMethodHelper(), getCallOptions()), responseObserver);
} }
@ -524,7 +524,7 @@ public final class TestServiceGrpc {
* The server returns the client payload as-is. * The server returns the client payload as-is.
* </pre> * </pre>
*/ */
public io.grpc.testing.integration.Test.SimpleResponse unaryCall(io.grpc.testing.integration.Test.SimpleRequest request) { public io.grpc.testing.compiler.Test.SimpleResponse unaryCall(io.grpc.testing.compiler.Test.SimpleRequest request) {
return blockingUnaryCall( return blockingUnaryCall(
getChannel(), getUnaryCallMethodHelper(), getCallOptions(), request); getChannel(), getUnaryCallMethodHelper(), getCallOptions(), request);
} }
@ -535,8 +535,8 @@ public final class TestServiceGrpc {
* The server returns the payload with client desired type and sizes. * The server returns the payload with client desired type and sizes.
* </pre> * </pre>
*/ */
public java.util.Iterator<io.grpc.testing.integration.Test.StreamingOutputCallResponse> streamingOutputCall( public java.util.Iterator<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> streamingOutputCall(
io.grpc.testing.integration.Test.StreamingOutputCallRequest request) { io.grpc.testing.compiler.Test.StreamingOutputCallRequest request) {
return blockingServerStreamingCall( return blockingServerStreamingCall(
getChannel(), getStreamingOutputCallMethodHelper(), getCallOptions(), request); getChannel(), getStreamingOutputCallMethodHelper(), getCallOptions(), request);
} }
@ -569,8 +569,8 @@ public final class TestServiceGrpc {
* The server returns the client payload as-is. * The server returns the client payload as-is.
* </pre> * </pre>
*/ */
public com.google.common.util.concurrent.ListenableFuture<io.grpc.testing.integration.Test.SimpleResponse> unaryCall( public com.google.common.util.concurrent.ListenableFuture<io.grpc.testing.compiler.Test.SimpleResponse> unaryCall(
io.grpc.testing.integration.Test.SimpleRequest request) { io.grpc.testing.compiler.Test.SimpleRequest request) {
return futureUnaryCall( return futureUnaryCall(
getChannel().newCall(getUnaryCallMethodHelper(), getCallOptions()), request); getChannel().newCall(getUnaryCallMethodHelper(), getCallOptions()), request);
} }
@ -601,12 +601,12 @@ public final class TestServiceGrpc {
public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) { public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) {
switch (methodId) { switch (methodId) {
case METHODID_UNARY_CALL: case METHODID_UNARY_CALL:
serviceImpl.unaryCall((io.grpc.testing.integration.Test.SimpleRequest) request, serviceImpl.unaryCall((io.grpc.testing.compiler.Test.SimpleRequest) request,
(io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.SimpleResponse>) responseObserver); (io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse>) responseObserver);
break; break;
case METHODID_STREAMING_OUTPUT_CALL: case METHODID_STREAMING_OUTPUT_CALL:
serviceImpl.streamingOutputCall((io.grpc.testing.integration.Test.StreamingOutputCallRequest) request, serviceImpl.streamingOutputCall((io.grpc.testing.compiler.Test.StreamingOutputCallRequest) request,
(io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallResponse>) responseObserver); (io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse>) responseObserver);
break; break;
default: default:
throw new AssertionError(); throw new AssertionError();
@ -620,16 +620,16 @@ public final class TestServiceGrpc {
switch (methodId) { switch (methodId) {
case METHODID_STREAMING_INPUT_CALL: case METHODID_STREAMING_INPUT_CALL:
return (io.grpc.stub.StreamObserver<Req>) serviceImpl.streamingInputCall( return (io.grpc.stub.StreamObserver<Req>) serviceImpl.streamingInputCall(
(io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingInputCallResponse>) responseObserver); (io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallResponse>) responseObserver);
case METHODID_FULL_BIDI_CALL: case METHODID_FULL_BIDI_CALL:
return (io.grpc.stub.StreamObserver<Req>) serviceImpl.fullBidiCall( return (io.grpc.stub.StreamObserver<Req>) serviceImpl.fullBidiCall(
(io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallResponse>) responseObserver); (io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse>) responseObserver);
case METHODID_HALF_BIDI_CALL: case METHODID_HALF_BIDI_CALL:
return (io.grpc.stub.StreamObserver<Req>) serviceImpl.halfBidiCall( return (io.grpc.stub.StreamObserver<Req>) serviceImpl.halfBidiCall(
(io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallResponse>) responseObserver); (io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse>) responseObserver);
case METHODID_IMPORT: case METHODID_IMPORT:
return (io.grpc.stub.StreamObserver<Req>) serviceImpl.import_( return (io.grpc.stub.StreamObserver<Req>) serviceImpl.import_(
(io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingInputCallResponse>) responseObserver); (io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallResponse>) responseObserver);
default: default:
throw new AssertionError(); throw new AssertionError();
} }
@ -642,7 +642,7 @@ public final class TestServiceGrpc {
@java.lang.Override @java.lang.Override
public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() { public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
return io.grpc.testing.integration.Test.getDescriptor(); return io.grpc.testing.compiler.Test.getDescriptor();
} }
@java.lang.Override @java.lang.Override

19
compiler/src/test/proto/test.proto → compiler/src/test/proto/grpc/testing/compiler/test.proto
View File

@ -1,9 +1,24 @@
// Copyright 2015, gRPC Authors
// All rights reserved.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
// A simple service definition for testing the protoc plugin. // A simple service definition for testing the protoc plugin.
syntax = "proto3"; syntax = "proto3";
package grpc.testing; package grpc.testing.compiler;
option java_package = "io.grpc.testing.integration"; option java_package = "io.grpc.testing.compiler";
message SimpleRequest { message SimpleRequest {
} }

260
compiler/src/testLite/golden/TestService.java.txt
View File

@ -1,4 +1,4 @@
package io.grpc.testing.integration; package io.grpc.testing.compiler;
import static io.grpc.MethodDescriptor.generateFullMethodName; import static io.grpc.MethodDescriptor.generateFullMethodName;
import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall; import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
@ -22,44 +22,44 @@ import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
*/ */
@javax.annotation.Generated( @javax.annotation.Generated(
value = "by gRPC proto compiler (version 1.13.0-SNAPSHOT)", value = "by gRPC proto compiler (version 1.13.0-SNAPSHOT)",
comments = "Source: test.proto") comments = "Source: grpc/testing/compiler/test.proto")
public final class TestServiceGrpc { public final class TestServiceGrpc {
private TestServiceGrpc() {} private TestServiceGrpc() {}
public static final String SERVICE_NAME = "grpc.testing.TestService"; public static final String SERVICE_NAME = "grpc.testing.compiler.TestService";
// Static method descriptors that strictly reflect the proto. // Static method descriptors that strictly reflect the proto.
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
@java.lang.Deprecated // Use {@link #getUnaryCallMethod()} instead. @java.lang.Deprecated // Use {@link #getUnaryCallMethod()} instead.
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.SimpleRequest, public static final io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest,
io.grpc.testing.integration.Test.SimpleResponse> METHOD_UNARY_CALL = getUnaryCallMethodHelper(); io.grpc.testing.compiler.Test.SimpleResponse> METHOD_UNARY_CALL = getUnaryCallMethodHelper();
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.SimpleRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest,
io.grpc.testing.integration.Test.SimpleResponse> getUnaryCallMethod; io.grpc.testing.compiler.Test.SimpleResponse> getUnaryCallMethod;
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
public static io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.SimpleRequest, public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest,
io.grpc.testing.integration.Test.SimpleResponse> getUnaryCallMethod() { io.grpc.testing.compiler.Test.SimpleResponse> getUnaryCallMethod() {
return getUnaryCallMethodHelper(); return getUnaryCallMethodHelper();
} }
private static io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.SimpleRequest, private static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest,
io.grpc.testing.integration.Test.SimpleResponse> getUnaryCallMethodHelper() { io.grpc.testing.compiler.Test.SimpleResponse> getUnaryCallMethodHelper() {
io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.SimpleRequest, io.grpc.testing.integration.Test.SimpleResponse> getUnaryCallMethod; io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Test.SimpleResponse> getUnaryCallMethod;
if ((getUnaryCallMethod = TestServiceGrpc.getUnaryCallMethod) == null) { if ((getUnaryCallMethod = TestServiceGrpc.getUnaryCallMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getUnaryCallMethod = TestServiceGrpc.getUnaryCallMethod) == null) { if ((getUnaryCallMethod = TestServiceGrpc.getUnaryCallMethod) == null) {
TestServiceGrpc.getUnaryCallMethod = getUnaryCallMethod = TestServiceGrpc.getUnaryCallMethod = getUnaryCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Test.SimpleRequest, io.grpc.testing.integration.Test.SimpleResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Test.SimpleResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(
"grpc.testing.TestService", "UnaryCall")) "grpc.testing.compiler.TestService", "UnaryCall"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
io.grpc.testing.integration.Test.SimpleRequest.getDefaultInstance())) io.grpc.testing.compiler.Test.SimpleRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
io.grpc.testing.integration.Test.SimpleResponse.getDefaultInstance())) io.grpc.testing.compiler.Test.SimpleResponse.getDefaultInstance()))
.build(); .build();
} }
} }
@ -68,34 +68,34 @@ public final class TestServiceGrpc {
} }
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
@java.lang.Deprecated // Use {@link #getStreamingOutputCallMethod()} instead. @java.lang.Deprecated // Use {@link #getStreamingOutputCallMethod()} instead.
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest, public static final io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.Test.StreamingOutputCallResponse> METHOD_STREAMING_OUTPUT_CALL = getStreamingOutputCallMethodHelper(); io.grpc.testing.compiler.Test.StreamingOutputCallResponse> METHOD_STREAMING_OUTPUT_CALL = getStreamingOutputCallMethodHelper();
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod; io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod;
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
public static io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest, public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod() { io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod() {
return getStreamingOutputCallMethodHelper(); return getStreamingOutputCallMethodHelper();
} }
private static io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest, private static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.Test.StreamingOutputCallResponse> getStreamingOutputCallMethodHelper() { io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getStreamingOutputCallMethodHelper() {
io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest, io.grpc.testing.integration.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod; io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod;
if ((getStreamingOutputCallMethod = TestServiceGrpc.getStreamingOutputCallMethod) == null) { if ((getStreamingOutputCallMethod = TestServiceGrpc.getStreamingOutputCallMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getStreamingOutputCallMethod = TestServiceGrpc.getStreamingOutputCallMethod) == null) { if ((getStreamingOutputCallMethod = TestServiceGrpc.getStreamingOutputCallMethod) == null) {
TestServiceGrpc.getStreamingOutputCallMethod = getStreamingOutputCallMethod = TestServiceGrpc.getStreamingOutputCallMethod = getStreamingOutputCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Test.StreamingOutputCallRequest, io.grpc.testing.integration.Test.StreamingOutputCallResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(
"grpc.testing.TestService", "StreamingOutputCall")) "grpc.testing.compiler.TestService", "StreamingOutputCall"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
io.grpc.testing.integration.Test.StreamingOutputCallRequest.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingOutputCallRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
io.grpc.testing.integration.Test.StreamingOutputCallResponse.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingOutputCallResponse.getDefaultInstance()))
.build(); .build();
} }
} }
@ -104,34 +104,34 @@ public final class TestServiceGrpc {
} }
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
@java.lang.Deprecated // Use {@link #getStreamingInputCallMethod()} instead. @java.lang.Deprecated // Use {@link #getStreamingInputCallMethod()} instead.
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingInputCallRequest, public static final io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
io.grpc.testing.integration.Test.StreamingInputCallResponse> METHOD_STREAMING_INPUT_CALL = getStreamingInputCallMethodHelper(); io.grpc.testing.compiler.Test.StreamingInputCallResponse> METHOD_STREAMING_INPUT_CALL = getStreamingInputCallMethodHelper();
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingInputCallRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
io.grpc.testing.integration.Test.StreamingInputCallResponse> getStreamingInputCallMethod; io.grpc.testing.compiler.Test.StreamingInputCallResponse> getStreamingInputCallMethod;
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
public static io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingInputCallRequest, public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
io.grpc.testing.integration.Test.StreamingInputCallResponse> getStreamingInputCallMethod() { io.grpc.testing.compiler.Test.StreamingInputCallResponse> getStreamingInputCallMethod() {
return getStreamingInputCallMethodHelper(); return getStreamingInputCallMethodHelper();
} }
private static io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingInputCallRequest, private static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
io.grpc.testing.integration.Test.StreamingInputCallResponse> getStreamingInputCallMethodHelper() { io.grpc.testing.compiler.Test.StreamingInputCallResponse> getStreamingInputCallMethodHelper() {
io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingInputCallRequest, io.grpc.testing.integration.Test.StreamingInputCallResponse> getStreamingInputCallMethod; io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest, io.grpc.testing.compiler.Test.StreamingInputCallResponse> getStreamingInputCallMethod;
if ((getStreamingInputCallMethod = TestServiceGrpc.getStreamingInputCallMethod) == null) { if ((getStreamingInputCallMethod = TestServiceGrpc.getStreamingInputCallMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getStreamingInputCallMethod = TestServiceGrpc.getStreamingInputCallMethod) == null) { if ((getStreamingInputCallMethod = TestServiceGrpc.getStreamingInputCallMethod) == null) {
TestServiceGrpc.getStreamingInputCallMethod = getStreamingInputCallMethod = TestServiceGrpc.getStreamingInputCallMethod = getStreamingInputCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Test.StreamingInputCallRequest, io.grpc.testing.integration.Test.StreamingInputCallResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingInputCallRequest, io.grpc.testing.compiler.Test.StreamingInputCallResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(
"grpc.testing.TestService", "StreamingInputCall")) "grpc.testing.compiler.TestService", "StreamingInputCall"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
io.grpc.testing.integration.Test.StreamingInputCallRequest.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingInputCallRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
io.grpc.testing.integration.Test.StreamingInputCallResponse.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingInputCallResponse.getDefaultInstance()))
.build(); .build();
} }
} }
@ -140,34 +140,34 @@ public final class TestServiceGrpc {
} }
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
@java.lang.Deprecated // Use {@link #getFullBidiCallMethod()} instead. @java.lang.Deprecated // Use {@link #getFullBidiCallMethod()} instead.
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest, public static final io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.Test.StreamingOutputCallResponse> METHOD_FULL_BIDI_CALL = getFullBidiCallMethodHelper(); io.grpc.testing.compiler.Test.StreamingOutputCallResponse> METHOD_FULL_BIDI_CALL = getFullBidiCallMethodHelper();
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.Test.StreamingOutputCallResponse> getFullBidiCallMethod; io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getFullBidiCallMethod;
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
public static io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest, public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.Test.StreamingOutputCallResponse> getFullBidiCallMethod() { io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getFullBidiCallMethod() {
return getFullBidiCallMethodHelper(); return getFullBidiCallMethodHelper();
} }
private static io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest, private static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.Test.StreamingOutputCallResponse> getFullBidiCallMethodHelper() { io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getFullBidiCallMethodHelper() {
io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest, io.grpc.testing.integration.Test.StreamingOutputCallResponse> getFullBidiCallMethod; io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getFullBidiCallMethod;
if ((getFullBidiCallMethod = TestServiceGrpc.getFullBidiCallMethod) == null) { if ((getFullBidiCallMethod = TestServiceGrpc.getFullBidiCallMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getFullBidiCallMethod = TestServiceGrpc.getFullBidiCallMethod) == null) { if ((getFullBidiCallMethod = TestServiceGrpc.getFullBidiCallMethod) == null) {
TestServiceGrpc.getFullBidiCallMethod = getFullBidiCallMethod = TestServiceGrpc.getFullBidiCallMethod = getFullBidiCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Test.StreamingOutputCallRequest, io.grpc.testing.integration.Test.StreamingOutputCallResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(
"grpc.testing.TestService", "FullBidiCall")) "grpc.testing.compiler.TestService", "FullBidiCall"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
io.grpc.testing.integration.Test.StreamingOutputCallRequest.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingOutputCallRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
io.grpc.testing.integration.Test.StreamingOutputCallResponse.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingOutputCallResponse.getDefaultInstance()))
.build(); .build();
} }
} }
@ -176,34 +176,34 @@ public final class TestServiceGrpc {
} }
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
@java.lang.Deprecated // Use {@link #getHalfBidiCallMethod()} instead. @java.lang.Deprecated // Use {@link #getHalfBidiCallMethod()} instead.
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest, public static final io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.Test.StreamingOutputCallResponse> METHOD_HALF_BIDI_CALL = getHalfBidiCallMethodHelper(); io.grpc.testing.compiler.Test.StreamingOutputCallResponse> METHOD_HALF_BIDI_CALL = getHalfBidiCallMethodHelper();
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.Test.StreamingOutputCallResponse> getHalfBidiCallMethod; io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getHalfBidiCallMethod;
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
public static io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest, public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.Test.StreamingOutputCallResponse> getHalfBidiCallMethod() { io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getHalfBidiCallMethod() {
return getHalfBidiCallMethodHelper(); return getHalfBidiCallMethodHelper();
} }
private static io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest, private static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.Test.StreamingOutputCallResponse> getHalfBidiCallMethodHelper() { io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getHalfBidiCallMethodHelper() {
io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest, io.grpc.testing.integration.Test.StreamingOutputCallResponse> getHalfBidiCallMethod; io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getHalfBidiCallMethod;
if ((getHalfBidiCallMethod = TestServiceGrpc.getHalfBidiCallMethod) == null) { if ((getHalfBidiCallMethod = TestServiceGrpc.getHalfBidiCallMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getHalfBidiCallMethod = TestServiceGrpc.getHalfBidiCallMethod) == null) { if ((getHalfBidiCallMethod = TestServiceGrpc.getHalfBidiCallMethod) == null) {
TestServiceGrpc.getHalfBidiCallMethod = getHalfBidiCallMethod = TestServiceGrpc.getHalfBidiCallMethod = getHalfBidiCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Test.StreamingOutputCallRequest, io.grpc.testing.integration.Test.StreamingOutputCallResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(
"grpc.testing.TestService", "HalfBidiCall")) "grpc.testing.compiler.TestService", "HalfBidiCall"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
io.grpc.testing.integration.Test.StreamingOutputCallRequest.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingOutputCallRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
io.grpc.testing.integration.Test.StreamingOutputCallResponse.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingOutputCallResponse.getDefaultInstance()))
.build(); .build();
} }
} }
@ -212,34 +212,34 @@ public final class TestServiceGrpc {
} }
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
@java.lang.Deprecated // Use {@link #getImportMethod()} instead. @java.lang.Deprecated // Use {@link #getImportMethod()} instead.
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingInputCallRequest, public static final io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
io.grpc.testing.integration.Test.StreamingInputCallResponse> METHOD_IMPORT = getImportMethodHelper(); io.grpc.testing.compiler.Test.StreamingInputCallResponse> METHOD_IMPORT = getImportMethodHelper();
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingInputCallRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
io.grpc.testing.integration.Test.StreamingInputCallResponse> getImportMethod; io.grpc.testing.compiler.Test.StreamingInputCallResponse> getImportMethod;
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
public static io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingInputCallRequest, public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
io.grpc.testing.integration.Test.StreamingInputCallResponse> getImportMethod() { io.grpc.testing.compiler.Test.StreamingInputCallResponse> getImportMethod() {
return getImportMethodHelper(); return getImportMethodHelper();
} }
private static io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingInputCallRequest, private static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
io.grpc.testing.integration.Test.StreamingInputCallResponse> getImportMethodHelper() { io.grpc.testing.compiler.Test.StreamingInputCallResponse> getImportMethodHelper() {
io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingInputCallRequest, io.grpc.testing.integration.Test.StreamingInputCallResponse> getImportMethod; io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest, io.grpc.testing.compiler.Test.StreamingInputCallResponse> getImportMethod;
if ((getImportMethod = TestServiceGrpc.getImportMethod) == null) { if ((getImportMethod = TestServiceGrpc.getImportMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getImportMethod = TestServiceGrpc.getImportMethod) == null) { if ((getImportMethod = TestServiceGrpc.getImportMethod) == null) {
TestServiceGrpc.getImportMethod = getImportMethod = TestServiceGrpc.getImportMethod = getImportMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Test.StreamingInputCallRequest, io.grpc.testing.integration.Test.StreamingInputCallResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingInputCallRequest, io.grpc.testing.compiler.Test.StreamingInputCallResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(
"grpc.testing.TestService", "Import")) "grpc.testing.compiler.TestService", "Import"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
io.grpc.testing.integration.Test.StreamingInputCallRequest.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingInputCallRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
io.grpc.testing.integration.Test.StreamingInputCallResponse.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingInputCallResponse.getDefaultInstance()))
.build(); .build();
} }
} }
@ -283,8 +283,8 @@ public final class TestServiceGrpc {
* The server returns the client payload as-is. * The server returns the client payload as-is.
* </pre> * </pre>
*/ */
public void unaryCall(io.grpc.testing.integration.Test.SimpleRequest request, public void unaryCall(io.grpc.testing.compiler.Test.SimpleRequest request,
io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.SimpleResponse> responseObserver) { io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse> responseObserver) {
asyncUnimplementedUnaryCall(getUnaryCallMethodHelper(), responseObserver); asyncUnimplementedUnaryCall(getUnaryCallMethodHelper(), responseObserver);
} }
@ -294,8 +294,8 @@ public final class TestServiceGrpc {
* The server returns the payload with client desired type and sizes. * The server returns the payload with client desired type and sizes.
* </pre> * </pre>
*/ */
public void streamingOutputCall(io.grpc.testing.integration.Test.StreamingOutputCallRequest request, public void streamingOutputCall(io.grpc.testing.compiler.Test.StreamingOutputCallRequest request,
io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallResponse> responseObserver) { io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObserver) {
asyncUnimplementedUnaryCall(getStreamingOutputCallMethodHelper(), responseObserver); asyncUnimplementedUnaryCall(getStreamingOutputCallMethodHelper(), responseObserver);
} }
@ -305,8 +305,8 @@ public final class TestServiceGrpc {
* The server returns the aggregated size of client payload as the result. * The server returns the aggregated size of client payload as the result.
* </pre> * </pre>
*/ */
public io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingInputCallRequest> streamingInputCall( public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallRequest> streamingInputCall(
io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingInputCallResponse> responseObserver) { io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallResponse> responseObserver) {
return asyncUnimplementedStreamingCall(getStreamingInputCallMethodHelper(), responseObserver); return asyncUnimplementedStreamingCall(getStreamingInputCallMethodHelper(), responseObserver);
} }
@ -317,8 +317,8 @@ public final class TestServiceGrpc {
* demonstrates the idea of full bidirectionality. * demonstrates the idea of full bidirectionality.
* </pre> * </pre>
*/ */
public io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallRequest> fullBidiCall( public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallRequest> fullBidiCall(
io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallResponse> responseObserver) { io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObserver) {
return asyncUnimplementedStreamingCall(getFullBidiCallMethodHelper(), responseObserver); return asyncUnimplementedStreamingCall(getFullBidiCallMethodHelper(), responseObserver);
} }
@ -330,8 +330,8 @@ public final class TestServiceGrpc {
* first request. * first request.
* </pre> * </pre>
*/ */
public io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallRequest> halfBidiCall( public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallRequest> halfBidiCall(
io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallResponse> responseObserver) { io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObserver) {
return asyncUnimplementedStreamingCall(getHalfBidiCallMethodHelper(), responseObserver); return asyncUnimplementedStreamingCall(getHalfBidiCallMethodHelper(), responseObserver);
} }
@ -341,8 +341,8 @@ public final class TestServiceGrpc {
* method should have a '_' appended. * method should have a '_' appended.
* </pre> * </pre>
*/ */
public io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingInputCallRequest> import_( public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallRequest> import_(
io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingInputCallResponse> responseObserver) { io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallResponse> responseObserver) {
return asyncUnimplementedStreamingCall(getImportMethodHelper(), responseObserver); return asyncUnimplementedStreamingCall(getImportMethodHelper(), responseObserver);
} }
@ -352,43 +352,43 @@ public final class TestServiceGrpc {
getUnaryCallMethodHelper(), getUnaryCallMethodHelper(),
asyncUnaryCall( asyncUnaryCall(
new MethodHandlers< new MethodHandlers<
io.grpc.testing.integration.Test.SimpleRequest, io.grpc.testing.compiler.Test.SimpleRequest,
io.grpc.testing.integration.Test.SimpleResponse>( io.grpc.testing.compiler.Test.SimpleResponse>(
this, METHODID_UNARY_CALL))) this, METHODID_UNARY_CALL)))
.addMethod( .addMethod(
getStreamingOutputCallMethodHelper(), getStreamingOutputCallMethodHelper(),
asyncServerStreamingCall( asyncServerStreamingCall(
new MethodHandlers< new MethodHandlers<
io.grpc.testing.integration.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.Test.StreamingOutputCallResponse>( io.grpc.testing.compiler.Test.StreamingOutputCallResponse>(
this, METHODID_STREAMING_OUTPUT_CALL))) this, METHODID_STREAMING_OUTPUT_CALL)))
.addMethod( .addMethod(
getStreamingInputCallMethodHelper(), getStreamingInputCallMethodHelper(),
asyncClientStreamingCall( asyncClientStreamingCall(
new MethodHandlers< new MethodHandlers<
io.grpc.testing.integration.Test.StreamingInputCallRequest, io.grpc.testing.compiler.Test.StreamingInputCallRequest,
io.grpc.testing.integration.Test.StreamingInputCallResponse>( io.grpc.testing.compiler.Test.StreamingInputCallResponse>(
this, METHODID_STREAMING_INPUT_CALL))) this, METHODID_STREAMING_INPUT_CALL)))
.addMethod( .addMethod(
getFullBidiCallMethodHelper(), getFullBidiCallMethodHelper(),
asyncBidiStreamingCall( asyncBidiStreamingCall(
new MethodHandlers< new MethodHandlers<
io.grpc.testing.integration.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.Test.StreamingOutputCallResponse>( io.grpc.testing.compiler.Test.StreamingOutputCallResponse>(
this, METHODID_FULL_BIDI_CALL))) this, METHODID_FULL_BIDI_CALL)))
.addMethod( .addMethod(
getHalfBidiCallMethodHelper(), getHalfBidiCallMethodHelper(),
asyncBidiStreamingCall( asyncBidiStreamingCall(
new MethodHandlers< new MethodHandlers<
io.grpc.testing.integration.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.Test.StreamingOutputCallResponse>( io.grpc.testing.compiler.Test.StreamingOutputCallResponse>(
this, METHODID_HALF_BIDI_CALL))) this, METHODID_HALF_BIDI_CALL)))
.addMethod( .addMethod(
getImportMethodHelper(), getImportMethodHelper(),
asyncBidiStreamingCall( asyncBidiStreamingCall(
new MethodHandlers< new MethodHandlers<
io.grpc.testing.integration.Test.StreamingInputCallRequest, io.grpc.testing.compiler.Test.StreamingInputCallRequest,
io.grpc.testing.integration.Test.StreamingInputCallResponse>( io.grpc.testing.compiler.Test.StreamingInputCallResponse>(
this, METHODID_IMPORT))) this, METHODID_IMPORT)))
.build(); .build();
} }
@ -421,8 +421,8 @@ public final class TestServiceGrpc {
* The server returns the client payload as-is. * The server returns the client payload as-is.
* </pre> * </pre>
*/ */
public void unaryCall(io.grpc.testing.integration.Test.SimpleRequest request, public void unaryCall(io.grpc.testing.compiler.Test.SimpleRequest request,
io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.SimpleResponse> responseObserver) { io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse> responseObserver) {
asyncUnaryCall( asyncUnaryCall(
getChannel().newCall(getUnaryCallMethodHelper(), getCallOptions()), request, responseObserver); getChannel().newCall(getUnaryCallMethodHelper(), getCallOptions()), request, responseObserver);
} }
@ -433,8 +433,8 @@ public final class TestServiceGrpc {
* The server returns the payload with client desired type and sizes. * The server returns the payload with client desired type and sizes.
* </pre> * </pre>
*/ */
public void streamingOutputCall(io.grpc.testing.integration.Test.StreamingOutputCallRequest request, public void streamingOutputCall(io.grpc.testing.compiler.Test.StreamingOutputCallRequest request,
io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallResponse> responseObserver) { io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObserver) {
asyncServerStreamingCall( asyncServerStreamingCall(
getChannel().newCall(getStreamingOutputCallMethodHelper(), getCallOptions()), request, responseObserver); getChannel().newCall(getStreamingOutputCallMethodHelper(), getCallOptions()), request, responseObserver);
} }
@ -445,8 +445,8 @@ public final class TestServiceGrpc {
* The server returns the aggregated size of client payload as the result. * The server returns the aggregated size of client payload as the result.
* </pre> * </pre>
*/ */
public io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingInputCallRequest> streamingInputCall( public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallRequest> streamingInputCall(
io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingInputCallResponse> responseObserver) { io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallResponse> responseObserver) {
return asyncClientStreamingCall( return asyncClientStreamingCall(
getChannel().newCall(getStreamingInputCallMethodHelper(), getCallOptions()), responseObserver); getChannel().newCall(getStreamingInputCallMethodHelper(), getCallOptions()), responseObserver);
} }
@ -458,8 +458,8 @@ public final class TestServiceGrpc {
* demonstrates the idea of full bidirectionality. * demonstrates the idea of full bidirectionality.
* </pre> * </pre>
*/ */
public io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallRequest> fullBidiCall( public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallRequest> fullBidiCall(
io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallResponse> responseObserver) { io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObserver) {
return asyncBidiStreamingCall( return asyncBidiStreamingCall(
getChannel().newCall(getFullBidiCallMethodHelper(), getCallOptions()), responseObserver); getChannel().newCall(getFullBidiCallMethodHelper(), getCallOptions()), responseObserver);
} }
@ -472,8 +472,8 @@ public final class TestServiceGrpc {
* first request. * first request.
* </pre> * </pre>
*/ */
public io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallRequest> halfBidiCall( public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallRequest> halfBidiCall(
io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallResponse> responseObserver) { io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObserver) {
return asyncBidiStreamingCall( return asyncBidiStreamingCall(
getChannel().newCall(getHalfBidiCallMethodHelper(), getCallOptions()), responseObserver); getChannel().newCall(getHalfBidiCallMethodHelper(), getCallOptions()), responseObserver);
} }
@ -484,8 +484,8 @@ public final class TestServiceGrpc {
* method should have a '_' appended. * method should have a '_' appended.
* </pre> * </pre>
*/ */
public io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingInputCallRequest> import_( public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallRequest> import_(
io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingInputCallResponse> responseObserver) { io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallResponse> responseObserver) {
return asyncBidiStreamingCall( return asyncBidiStreamingCall(
getChannel().newCall(getImportMethodHelper(), getCallOptions()), responseObserver); getChannel().newCall(getImportMethodHelper(), getCallOptions()), responseObserver);
} }
@ -518,7 +518,7 @@ public final class TestServiceGrpc {
* The server returns the client payload as-is. * The server returns the client payload as-is.
* </pre> * </pre>
*/ */
public io.grpc.testing.integration.Test.SimpleResponse unaryCall(io.grpc.testing.integration.Test.SimpleRequest request) { public io.grpc.testing.compiler.Test.SimpleResponse unaryCall(io.grpc.testing.compiler.Test.SimpleRequest request) {
return blockingUnaryCall( return blockingUnaryCall(
getChannel(), getUnaryCallMethodHelper(), getCallOptions(), request); getChannel(), getUnaryCallMethodHelper(), getCallOptions(), request);
} }
@ -529,8 +529,8 @@ public final class TestServiceGrpc {
* The server returns the payload with client desired type and sizes. * The server returns the payload with client desired type and sizes.
* </pre> * </pre>
*/ */
public java.util.Iterator<io.grpc.testing.integration.Test.StreamingOutputCallResponse> streamingOutputCall( public java.util.Iterator<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> streamingOutputCall(
io.grpc.testing.integration.Test.StreamingOutputCallRequest request) { io.grpc.testing.compiler.Test.StreamingOutputCallRequest request) {
return blockingServerStreamingCall( return blockingServerStreamingCall(
getChannel(), getStreamingOutputCallMethodHelper(), getCallOptions(), request); getChannel(), getStreamingOutputCallMethodHelper(), getCallOptions(), request);
} }
@ -563,8 +563,8 @@ public final class TestServiceGrpc {
* The server returns the client payload as-is. * The server returns the client payload as-is.
* </pre> * </pre>
*/ */
public com.google.common.util.concurrent.ListenableFuture<io.grpc.testing.integration.Test.SimpleResponse> unaryCall( public com.google.common.util.concurrent.ListenableFuture<io.grpc.testing.compiler.Test.SimpleResponse> unaryCall(
io.grpc.testing.integration.Test.SimpleRequest request) { io.grpc.testing.compiler.Test.SimpleRequest request) {
return futureUnaryCall( return futureUnaryCall(
getChannel().newCall(getUnaryCallMethodHelper(), getCallOptions()), request); getChannel().newCall(getUnaryCallMethodHelper(), getCallOptions()), request);
} }
@ -595,12 +595,12 @@ public final class TestServiceGrpc {
public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) { public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) {
switch (methodId) { switch (methodId) {
case METHODID_UNARY_CALL: case METHODID_UNARY_CALL:
serviceImpl.unaryCall((io.grpc.testing.integration.Test.SimpleRequest) request, serviceImpl.unaryCall((io.grpc.testing.compiler.Test.SimpleRequest) request,
(io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.SimpleResponse>) responseObserver); (io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse>) responseObserver);
break; break;
case METHODID_STREAMING_OUTPUT_CALL: case METHODID_STREAMING_OUTPUT_CALL:
serviceImpl.streamingOutputCall((io.grpc.testing.integration.Test.StreamingOutputCallRequest) request, serviceImpl.streamingOutputCall((io.grpc.testing.compiler.Test.StreamingOutputCallRequest) request,
(io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallResponse>) responseObserver); (io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse>) responseObserver);
break; break;
default: default:
throw new AssertionError(); throw new AssertionError();
@ -614,16 +614,16 @@ public final class TestServiceGrpc {
switch (methodId) { switch (methodId) {
case METHODID_STREAMING_INPUT_CALL: case METHODID_STREAMING_INPUT_CALL:
return (io.grpc.stub.StreamObserver<Req>) serviceImpl.streamingInputCall( return (io.grpc.stub.StreamObserver<Req>) serviceImpl.streamingInputCall(
(io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingInputCallResponse>) responseObserver); (io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallResponse>) responseObserver);
case METHODID_FULL_BIDI_CALL: case METHODID_FULL_BIDI_CALL:
return (io.grpc.stub.StreamObserver<Req>) serviceImpl.fullBidiCall( return (io.grpc.stub.StreamObserver<Req>) serviceImpl.fullBidiCall(
(io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallResponse>) responseObserver); (io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse>) responseObserver);
case METHODID_HALF_BIDI_CALL: case METHODID_HALF_BIDI_CALL:
return (io.grpc.stub.StreamObserver<Req>) serviceImpl.halfBidiCall( return (io.grpc.stub.StreamObserver<Req>) serviceImpl.halfBidiCall(
(io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingOutputCallResponse>) responseObserver); (io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse>) responseObserver);
case METHODID_IMPORT: case METHODID_IMPORT:
return (io.grpc.stub.StreamObserver<Req>) serviceImpl.import_( return (io.grpc.stub.StreamObserver<Req>) serviceImpl.import_(
(io.grpc.stub.StreamObserver<io.grpc.testing.integration.Test.StreamingInputCallResponse>) responseObserver); (io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallResponse>) responseObserver);
default: default:
throw new AssertionError(); throw new AssertionError();
} }

308
compiler/src/testNano/golden/TestService.java.txt
View File

@ -1,4 +1,4 @@
package io.grpc.testing.integration.nano; package io.grpc.testing.compiler.nano;
import static io.grpc.MethodDescriptor.generateFullMethodName; import static io.grpc.MethodDescriptor.generateFullMethodName;
import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall; import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
@ -24,46 +24,46 @@ import java.io.IOException;
*/ */
@javax.annotation.Generated( @javax.annotation.Generated(
value = "by gRPC proto compiler (version 1.13.0-SNAPSHOT)", value = "by gRPC proto compiler (version 1.13.0-SNAPSHOT)",
comments = "Source: test.proto") comments = "Source: grpc/testing/compiler/test.proto")
public final class TestServiceGrpc { public final class TestServiceGrpc {
private TestServiceGrpc() {} private TestServiceGrpc() {}
public static final String SERVICE_NAME = "grpc.testing.TestService"; public static final String SERVICE_NAME = "grpc.testing.compiler.TestService";
// Static method descriptors that strictly reflect the proto. // Static method descriptors that strictly reflect the proto.
private static final int ARG_IN_METHOD_UNARY_CALL = 0; private static final int ARG_IN_METHOD_UNARY_CALL = 0;
private static final int ARG_OUT_METHOD_UNARY_CALL = 1; private static final int ARG_OUT_METHOD_UNARY_CALL = 1;
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
@java.lang.Deprecated // Use {@link #getUnaryCallMethod()} instead. @java.lang.Deprecated // Use {@link #getUnaryCallMethod()} instead.
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.SimpleRequest, public static final io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.SimpleRequest,
io.grpc.testing.integration.nano.Test.SimpleResponse> METHOD_UNARY_CALL = getUnaryCallMethodHelper(); io.grpc.testing.compiler.nano.Test.SimpleResponse> METHOD_UNARY_CALL = getUnaryCallMethodHelper();
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.SimpleRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.SimpleRequest,
io.grpc.testing.integration.nano.Test.SimpleResponse> getUnaryCallMethod; io.grpc.testing.compiler.nano.Test.SimpleResponse> getUnaryCallMethod;
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
public static io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.SimpleRequest, public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.SimpleRequest,
io.grpc.testing.integration.nano.Test.SimpleResponse> getUnaryCallMethod() { io.grpc.testing.compiler.nano.Test.SimpleResponse> getUnaryCallMethod() {
return getUnaryCallMethodHelper(); return getUnaryCallMethodHelper();
} }
private static io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.SimpleRequest, private static io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.SimpleRequest,
io.grpc.testing.integration.nano.Test.SimpleResponse> getUnaryCallMethodHelper() { io.grpc.testing.compiler.nano.Test.SimpleResponse> getUnaryCallMethodHelper() {
io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.SimpleRequest, io.grpc.testing.integration.nano.Test.SimpleResponse> getUnaryCallMethod; io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.SimpleRequest, io.grpc.testing.compiler.nano.Test.SimpleResponse> getUnaryCallMethod;
if ((getUnaryCallMethod = TestServiceGrpc.getUnaryCallMethod) == null) { if ((getUnaryCallMethod = TestServiceGrpc.getUnaryCallMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getUnaryCallMethod = TestServiceGrpc.getUnaryCallMethod) == null) { if ((getUnaryCallMethod = TestServiceGrpc.getUnaryCallMethod) == null) {
TestServiceGrpc.getUnaryCallMethod = getUnaryCallMethod = TestServiceGrpc.getUnaryCallMethod = getUnaryCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.integration.nano.Test.SimpleRequest, io.grpc.testing.integration.nano.Test.SimpleResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.compiler.nano.Test.SimpleRequest, io.grpc.testing.compiler.nano.Test.SimpleResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(
"grpc.testing.TestService", "UnaryCall")) "grpc.testing.compiler.TestService", "UnaryCall"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.integration.nano.Test.SimpleRequest>marshaller( .setRequestMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.SimpleRequest>marshaller(
new NanoFactory<io.grpc.testing.integration.nano.Test.SimpleRequest>(ARG_IN_METHOD_UNARY_CALL))) new NanoFactory<io.grpc.testing.compiler.nano.Test.SimpleRequest>(ARG_IN_METHOD_UNARY_CALL)))
.setResponseMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.integration.nano.Test.SimpleResponse>marshaller( .setResponseMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.SimpleResponse>marshaller(
new NanoFactory<io.grpc.testing.integration.nano.Test.SimpleResponse>(ARG_OUT_METHOD_UNARY_CALL))) new NanoFactory<io.grpc.testing.compiler.nano.Test.SimpleResponse>(ARG_OUT_METHOD_UNARY_CALL)))
.build(); .build();
} }
} }
@ -74,34 +74,34 @@ public final class TestServiceGrpc {
private static final int ARG_OUT_METHOD_STREAMING_OUTPUT_CALL = 3; private static final int ARG_OUT_METHOD_STREAMING_OUTPUT_CALL = 3;
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
@java.lang.Deprecated // Use {@link #getStreamingOutputCallMethod()} instead. @java.lang.Deprecated // Use {@link #getStreamingOutputCallMethod()} instead.
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest, public static final io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse> METHOD_STREAMING_OUTPUT_CALL = getStreamingOutputCallMethodHelper(); io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> METHOD_STREAMING_OUTPUT_CALL = getStreamingOutputCallMethodHelper();
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod; io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod;
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
public static io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest, public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod() { io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod() {
return getStreamingOutputCallMethodHelper(); return getStreamingOutputCallMethodHelper();
} }
private static io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest, private static io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse> getStreamingOutputCallMethodHelper() { io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> getStreamingOutputCallMethodHelper() {
io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest, io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod; io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod;
if ((getStreamingOutputCallMethod = TestServiceGrpc.getStreamingOutputCallMethod) == null) { if ((getStreamingOutputCallMethod = TestServiceGrpc.getStreamingOutputCallMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getStreamingOutputCallMethod = TestServiceGrpc.getStreamingOutputCallMethod) == null) { if ((getStreamingOutputCallMethod = TestServiceGrpc.getStreamingOutputCallMethod) == null) {
TestServiceGrpc.getStreamingOutputCallMethod = getStreamingOutputCallMethod = TestServiceGrpc.getStreamingOutputCallMethod = getStreamingOutputCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest, io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(
"grpc.testing.TestService", "StreamingOutputCall")) "grpc.testing.compiler.TestService", "StreamingOutputCall"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest>marshaller( .setRequestMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest>marshaller(
new NanoFactory<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest>(ARG_IN_METHOD_STREAMING_OUTPUT_CALL))) new NanoFactory<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest>(ARG_IN_METHOD_STREAMING_OUTPUT_CALL)))
.setResponseMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse>marshaller( .setResponseMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse>marshaller(
new NanoFactory<io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse>(ARG_OUT_METHOD_STREAMING_OUTPUT_CALL))) new NanoFactory<io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse>(ARG_OUT_METHOD_STREAMING_OUTPUT_CALL)))
.build(); .build();
} }
} }
@ -112,34 +112,34 @@ public final class TestServiceGrpc {
private static final int ARG_OUT_METHOD_STREAMING_INPUT_CALL = 5; private static final int ARG_OUT_METHOD_STREAMING_INPUT_CALL = 5;
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
@java.lang.Deprecated // Use {@link #getStreamingInputCallMethod()} instead. @java.lang.Deprecated // Use {@link #getStreamingInputCallMethod()} instead.
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.StreamingInputCallRequest, public static final io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest,
io.grpc.testing.integration.nano.Test.StreamingInputCallResponse> METHOD_STREAMING_INPUT_CALL = getStreamingInputCallMethodHelper(); io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse> METHOD_STREAMING_INPUT_CALL = getStreamingInputCallMethodHelper();
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.StreamingInputCallRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest,
io.grpc.testing.integration.nano.Test.StreamingInputCallResponse> getStreamingInputCallMethod; io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse> getStreamingInputCallMethod;
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
public static io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.StreamingInputCallRequest, public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest,
io.grpc.testing.integration.nano.Test.StreamingInputCallResponse> getStreamingInputCallMethod() { io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse> getStreamingInputCallMethod() {
return getStreamingInputCallMethodHelper(); return getStreamingInputCallMethodHelper();
} }
private static io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.StreamingInputCallRequest, private static io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest,
io.grpc.testing.integration.nano.Test.StreamingInputCallResponse> getStreamingInputCallMethodHelper() { io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse> getStreamingInputCallMethodHelper() {
io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.StreamingInputCallRequest, io.grpc.testing.integration.nano.Test.StreamingInputCallResponse> getStreamingInputCallMethod; io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest, io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse> getStreamingInputCallMethod;
if ((getStreamingInputCallMethod = TestServiceGrpc.getStreamingInputCallMethod) == null) { if ((getStreamingInputCallMethod = TestServiceGrpc.getStreamingInputCallMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getStreamingInputCallMethod = TestServiceGrpc.getStreamingInputCallMethod) == null) { if ((getStreamingInputCallMethod = TestServiceGrpc.getStreamingInputCallMethod) == null) {
TestServiceGrpc.getStreamingInputCallMethod = getStreamingInputCallMethod = TestServiceGrpc.getStreamingInputCallMethod = getStreamingInputCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.integration.nano.Test.StreamingInputCallRequest, io.grpc.testing.integration.nano.Test.StreamingInputCallResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest, io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(
"grpc.testing.TestService", "StreamingInputCall")) "grpc.testing.compiler.TestService", "StreamingInputCall"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.integration.nano.Test.StreamingInputCallRequest>marshaller( .setRequestMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest>marshaller(
new NanoFactory<io.grpc.testing.integration.nano.Test.StreamingInputCallRequest>(ARG_IN_METHOD_STREAMING_INPUT_CALL))) new NanoFactory<io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest>(ARG_IN_METHOD_STREAMING_INPUT_CALL)))
.setResponseMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.integration.nano.Test.StreamingInputCallResponse>marshaller( .setResponseMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse>marshaller(
new NanoFactory<io.grpc.testing.integration.nano.Test.StreamingInputCallResponse>(ARG_OUT_METHOD_STREAMING_INPUT_CALL))) new NanoFactory<io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse>(ARG_OUT_METHOD_STREAMING_INPUT_CALL)))
.build(); .build();
} }
} }
@ -150,34 +150,34 @@ public final class TestServiceGrpc {
private static final int ARG_OUT_METHOD_FULL_BIDI_CALL = 7; private static final int ARG_OUT_METHOD_FULL_BIDI_CALL = 7;
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
@java.lang.Deprecated // Use {@link #getFullBidiCallMethod()} instead. @java.lang.Deprecated // Use {@link #getFullBidiCallMethod()} instead.
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest, public static final io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse> METHOD_FULL_BIDI_CALL = getFullBidiCallMethodHelper(); io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> METHOD_FULL_BIDI_CALL = getFullBidiCallMethodHelper();
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse> getFullBidiCallMethod; io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> getFullBidiCallMethod;
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
public static io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest, public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse> getFullBidiCallMethod() { io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> getFullBidiCallMethod() {
return getFullBidiCallMethodHelper(); return getFullBidiCallMethodHelper();
} }
private static io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest, private static io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse> getFullBidiCallMethodHelper() { io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> getFullBidiCallMethodHelper() {
io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest, io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse> getFullBidiCallMethod; io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> getFullBidiCallMethod;
if ((getFullBidiCallMethod = TestServiceGrpc.getFullBidiCallMethod) == null) { if ((getFullBidiCallMethod = TestServiceGrpc.getFullBidiCallMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getFullBidiCallMethod = TestServiceGrpc.getFullBidiCallMethod) == null) { if ((getFullBidiCallMethod = TestServiceGrpc.getFullBidiCallMethod) == null) {
TestServiceGrpc.getFullBidiCallMethod = getFullBidiCallMethod = TestServiceGrpc.getFullBidiCallMethod = getFullBidiCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest, io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(
"grpc.testing.TestService", "FullBidiCall")) "grpc.testing.compiler.TestService", "FullBidiCall"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest>marshaller( .setRequestMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest>marshaller(
new NanoFactory<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest>(ARG_IN_METHOD_FULL_BIDI_CALL))) new NanoFactory<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest>(ARG_IN_METHOD_FULL_BIDI_CALL)))
.setResponseMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse>marshaller( .setResponseMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse>marshaller(
new NanoFactory<io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse>(ARG_OUT_METHOD_FULL_BIDI_CALL))) new NanoFactory<io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse>(ARG_OUT_METHOD_FULL_BIDI_CALL)))
.build(); .build();
} }
} }
@ -188,34 +188,34 @@ public final class TestServiceGrpc {
private static final int ARG_OUT_METHOD_HALF_BIDI_CALL = 9; private static final int ARG_OUT_METHOD_HALF_BIDI_CALL = 9;
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
@java.lang.Deprecated // Use {@link #getHalfBidiCallMethod()} instead. @java.lang.Deprecated // Use {@link #getHalfBidiCallMethod()} instead.
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest, public static final io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse> METHOD_HALF_BIDI_CALL = getHalfBidiCallMethodHelper(); io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> METHOD_HALF_BIDI_CALL = getHalfBidiCallMethodHelper();
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse> getHalfBidiCallMethod; io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> getHalfBidiCallMethod;
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
public static io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest, public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse> getHalfBidiCallMethod() { io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> getHalfBidiCallMethod() {
return getHalfBidiCallMethodHelper(); return getHalfBidiCallMethodHelper();
} }
private static io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest, private static io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse> getHalfBidiCallMethodHelper() { io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> getHalfBidiCallMethodHelper() {
io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest, io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse> getHalfBidiCallMethod; io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> getHalfBidiCallMethod;
if ((getHalfBidiCallMethod = TestServiceGrpc.getHalfBidiCallMethod) == null) { if ((getHalfBidiCallMethod = TestServiceGrpc.getHalfBidiCallMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getHalfBidiCallMethod = TestServiceGrpc.getHalfBidiCallMethod) == null) { if ((getHalfBidiCallMethod = TestServiceGrpc.getHalfBidiCallMethod) == null) {
TestServiceGrpc.getHalfBidiCallMethod = getHalfBidiCallMethod = TestServiceGrpc.getHalfBidiCallMethod = getHalfBidiCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest, io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(
"grpc.testing.TestService", "HalfBidiCall")) "grpc.testing.compiler.TestService", "HalfBidiCall"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest>marshaller( .setRequestMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest>marshaller(
new NanoFactory<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest>(ARG_IN_METHOD_HALF_BIDI_CALL))) new NanoFactory<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest>(ARG_IN_METHOD_HALF_BIDI_CALL)))
.setResponseMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse>marshaller( .setResponseMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse>marshaller(
new NanoFactory<io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse>(ARG_OUT_METHOD_HALF_BIDI_CALL))) new NanoFactory<io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse>(ARG_OUT_METHOD_HALF_BIDI_CALL)))
.build(); .build();
} }
} }
@ -226,34 +226,34 @@ public final class TestServiceGrpc {
private static final int ARG_OUT_METHOD_IMPORT = 11; private static final int ARG_OUT_METHOD_IMPORT = 11;
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
@java.lang.Deprecated // Use {@link #getImportMethod()} instead. @java.lang.Deprecated // Use {@link #getImportMethod()} instead.
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.StreamingInputCallRequest, public static final io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest,
io.grpc.testing.integration.nano.Test.StreamingInputCallResponse> METHOD_IMPORT = getImportMethodHelper(); io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse> METHOD_IMPORT = getImportMethodHelper();
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.StreamingInputCallRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest,
io.grpc.testing.integration.nano.Test.StreamingInputCallResponse> getImportMethod; io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse> getImportMethod;
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
public static io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.StreamingInputCallRequest, public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest,
io.grpc.testing.integration.nano.Test.StreamingInputCallResponse> getImportMethod() { io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse> getImportMethod() {
return getImportMethodHelper(); return getImportMethodHelper();
} }
private static io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.StreamingInputCallRequest, private static io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest,
io.grpc.testing.integration.nano.Test.StreamingInputCallResponse> getImportMethodHelper() { io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse> getImportMethodHelper() {
io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.StreamingInputCallRequest, io.grpc.testing.integration.nano.Test.StreamingInputCallResponse> getImportMethod; io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest, io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse> getImportMethod;
if ((getImportMethod = TestServiceGrpc.getImportMethod) == null) { if ((getImportMethod = TestServiceGrpc.getImportMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getImportMethod = TestServiceGrpc.getImportMethod) == null) { if ((getImportMethod = TestServiceGrpc.getImportMethod) == null) {
TestServiceGrpc.getImportMethod = getImportMethod = TestServiceGrpc.getImportMethod = getImportMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.integration.nano.Test.StreamingInputCallRequest, io.grpc.testing.integration.nano.Test.StreamingInputCallResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest, io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(
"grpc.testing.TestService", "Import")) "grpc.testing.compiler.TestService", "Import"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.integration.nano.Test.StreamingInputCallRequest>marshaller( .setRequestMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest>marshaller(
new NanoFactory<io.grpc.testing.integration.nano.Test.StreamingInputCallRequest>(ARG_IN_METHOD_IMPORT))) new NanoFactory<io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest>(ARG_IN_METHOD_IMPORT)))
.setResponseMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.integration.nano.Test.StreamingInputCallResponse>marshaller( .setResponseMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse>marshaller(
new NanoFactory<io.grpc.testing.integration.nano.Test.StreamingInputCallResponse>(ARG_OUT_METHOD_IMPORT))) new NanoFactory<io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse>(ARG_OUT_METHOD_IMPORT)))
.build(); .build();
} }
} }
@ -274,40 +274,40 @@ public final class TestServiceGrpc {
Object o; Object o;
switch (id) { switch (id) {
case ARG_IN_METHOD_UNARY_CALL: case ARG_IN_METHOD_UNARY_CALL:
o = new io.grpc.testing.integration.nano.Test.SimpleRequest(); o = new io.grpc.testing.compiler.nano.Test.SimpleRequest();
break; break;
case ARG_OUT_METHOD_UNARY_CALL: case ARG_OUT_METHOD_UNARY_CALL:
o = new io.grpc.testing.integration.nano.Test.SimpleResponse(); o = new io.grpc.testing.compiler.nano.Test.SimpleResponse();
break; break;
case ARG_IN_METHOD_STREAMING_OUTPUT_CALL: case ARG_IN_METHOD_STREAMING_OUTPUT_CALL:
o = new io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest(); o = new io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest();
break; break;
case ARG_OUT_METHOD_STREAMING_OUTPUT_CALL: case ARG_OUT_METHOD_STREAMING_OUTPUT_CALL:
o = new io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse(); o = new io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse();
break; break;
case ARG_IN_METHOD_STREAMING_INPUT_CALL: case ARG_IN_METHOD_STREAMING_INPUT_CALL:
o = new io.grpc.testing.integration.nano.Test.StreamingInputCallRequest(); o = new io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest();
break; break;
case ARG_OUT_METHOD_STREAMING_INPUT_CALL: case ARG_OUT_METHOD_STREAMING_INPUT_CALL:
o = new io.grpc.testing.integration.nano.Test.StreamingInputCallResponse(); o = new io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse();
break; break;
case ARG_IN_METHOD_FULL_BIDI_CALL: case ARG_IN_METHOD_FULL_BIDI_CALL:
o = new io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest(); o = new io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest();
break; break;
case ARG_OUT_METHOD_FULL_BIDI_CALL: case ARG_OUT_METHOD_FULL_BIDI_CALL:
o = new io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse(); o = new io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse();
break; break;
case ARG_IN_METHOD_HALF_BIDI_CALL: case ARG_IN_METHOD_HALF_BIDI_CALL:
o = new io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest(); o = new io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest();
break; break;
case ARG_OUT_METHOD_HALF_BIDI_CALL: case ARG_OUT_METHOD_HALF_BIDI_CALL:
o = new io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse(); o = new io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse();
break; break;
case ARG_IN_METHOD_IMPORT: case ARG_IN_METHOD_IMPORT:
o = new io.grpc.testing.integration.nano.Test.StreamingInputCallRequest(); o = new io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest();
break; break;
case ARG_OUT_METHOD_IMPORT: case ARG_OUT_METHOD_IMPORT:
o = new io.grpc.testing.integration.nano.Test.StreamingInputCallResponse(); o = new io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse();
break; break;
default: default:
throw new AssertionError(); throw new AssertionError();
@ -354,8 +354,8 @@ public final class TestServiceGrpc {
* The server returns the client payload as-is. * The server returns the client payload as-is.
* </pre> * </pre>
*/ */
public void unaryCall(io.grpc.testing.integration.nano.Test.SimpleRequest request, public void unaryCall(io.grpc.testing.compiler.nano.Test.SimpleRequest request,
io.grpc.stub.StreamObserver<io.grpc.testing.integration.nano.Test.SimpleResponse> responseObserver) { io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.SimpleResponse> responseObserver) {
asyncUnimplementedUnaryCall(getUnaryCallMethodHelper(), responseObserver); asyncUnimplementedUnaryCall(getUnaryCallMethodHelper(), responseObserver);
} }
@ -365,8 +365,8 @@ public final class TestServiceGrpc {
* The server returns the payload with client desired type and sizes. * The server returns the payload with client desired type and sizes.
* </pre> * </pre>
*/ */
public void streamingOutputCall(io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest request, public void streamingOutputCall(io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest request,
io.grpc.stub.StreamObserver<io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse> responseObserver) { io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> responseObserver) {
asyncUnimplementedUnaryCall(getStreamingOutputCallMethodHelper(), responseObserver); asyncUnimplementedUnaryCall(getStreamingOutputCallMethodHelper(), responseObserver);
} }
@ -376,8 +376,8 @@ public final class TestServiceGrpc {
* The server returns the aggregated size of client payload as the result. * The server returns the aggregated size of client payload as the result.
* </pre> * </pre>
*/ */
public io.grpc.stub.StreamObserver<io.grpc.testing.integration.nano.Test.StreamingInputCallRequest> streamingInputCall( public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest> streamingInputCall(
io.grpc.stub.StreamObserver<io.grpc.testing.integration.nano.Test.StreamingInputCallResponse> responseObserver) { io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse> responseObserver) {
return asyncUnimplementedStreamingCall(getStreamingInputCallMethodHelper(), responseObserver); return asyncUnimplementedStreamingCall(getStreamingInputCallMethodHelper(), responseObserver);
} }
@ -388,8 +388,8 @@ public final class TestServiceGrpc {
* demonstrates the idea of full bidirectionality. * demonstrates the idea of full bidirectionality.
* </pre> * </pre>
*/ */
public io.grpc.stub.StreamObserver<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest> fullBidiCall( public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest> fullBidiCall(
io.grpc.stub.StreamObserver<io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse> responseObserver) { io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> responseObserver) {
return asyncUnimplementedStreamingCall(getFullBidiCallMethodHelper(), responseObserver); return asyncUnimplementedStreamingCall(getFullBidiCallMethodHelper(), responseObserver);
} }
@ -401,8 +401,8 @@ public final class TestServiceGrpc {
* first request. * first request.
* </pre> * </pre>
*/ */
public io.grpc.stub.StreamObserver<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest> halfBidiCall( public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest> halfBidiCall(
io.grpc.stub.StreamObserver<io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse> responseObserver) { io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> responseObserver) {
return asyncUnimplementedStreamingCall(getHalfBidiCallMethodHelper(), responseObserver); return asyncUnimplementedStreamingCall(getHalfBidiCallMethodHelper(), responseObserver);
} }
@ -412,8 +412,8 @@ public final class TestServiceGrpc {
* method should have a '_' appended. * method should have a '_' appended.
* </pre> * </pre>
*/ */
public io.grpc.stub.StreamObserver<io.grpc.testing.integration.nano.Test.StreamingInputCallRequest> import_( public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest> import_(
io.grpc.stub.StreamObserver<io.grpc.testing.integration.nano.Test.StreamingInputCallResponse> responseObserver) { io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse> responseObserver) {
return asyncUnimplementedStreamingCall(getImportMethodHelper(), responseObserver); return asyncUnimplementedStreamingCall(getImportMethodHelper(), responseObserver);
} }
@ -423,43 +423,43 @@ public final class TestServiceGrpc {
getUnaryCallMethodHelper(), getUnaryCallMethodHelper(),
asyncUnaryCall( asyncUnaryCall(
new MethodHandlers< new MethodHandlers<
io.grpc.testing.integration.nano.Test.SimpleRequest, io.grpc.testing.compiler.nano.Test.SimpleRequest,
io.grpc.testing.integration.nano.Test.SimpleResponse>( io.grpc.testing.compiler.nano.Test.SimpleResponse>(
this, METHODID_UNARY_CALL))) this, METHODID_UNARY_CALL)))
.addMethod( .addMethod(
getStreamingOutputCallMethodHelper(), getStreamingOutputCallMethodHelper(),
asyncServerStreamingCall( asyncServerStreamingCall(
new MethodHandlers< new MethodHandlers<
io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse>( io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse>(
this, METHODID_STREAMING_OUTPUT_CALL))) this, METHODID_STREAMING_OUTPUT_CALL)))
.addMethod( .addMethod(
getStreamingInputCallMethodHelper(), getStreamingInputCallMethodHelper(),
asyncClientStreamingCall( asyncClientStreamingCall(
new MethodHandlers< new MethodHandlers<
io.grpc.testing.integration.nano.Test.StreamingInputCallRequest, io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest,
io.grpc.testing.integration.nano.Test.StreamingInputCallResponse>( io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse>(
this, METHODID_STREAMING_INPUT_CALL))) this, METHODID_STREAMING_INPUT_CALL)))
.addMethod( .addMethod(
getFullBidiCallMethodHelper(), getFullBidiCallMethodHelper(),
asyncBidiStreamingCall( asyncBidiStreamingCall(
new MethodHandlers< new MethodHandlers<
io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse>( io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse>(
this, METHODID_FULL_BIDI_CALL))) this, METHODID_FULL_BIDI_CALL)))
.addMethod( .addMethod(
getHalfBidiCallMethodHelper(), getHalfBidiCallMethodHelper(),
asyncBidiStreamingCall( asyncBidiStreamingCall(
new MethodHandlers< new MethodHandlers<
io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest,
io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse>( io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse>(
this, METHODID_HALF_BIDI_CALL))) this, METHODID_HALF_BIDI_CALL)))
.addMethod( .addMethod(
getImportMethodHelper(), getImportMethodHelper(),
asyncBidiStreamingCall( asyncBidiStreamingCall(
new MethodHandlers< new MethodHandlers<
io.grpc.testing.integration.nano.Test.StreamingInputCallRequest, io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest,
io.grpc.testing.integration.nano.Test.StreamingInputCallResponse>( io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse>(
this, METHODID_IMPORT))) this, METHODID_IMPORT)))
.build(); .build();
} }
@ -492,8 +492,8 @@ public final class TestServiceGrpc {
* The server returns the client payload as-is. * The server returns the client payload as-is.
* </pre> * </pre>
*/ */
public void unaryCall(io.grpc.testing.integration.nano.Test.SimpleRequest request, public void unaryCall(io.grpc.testing.compiler.nano.Test.SimpleRequest request,
io.grpc.stub.StreamObserver<io.grpc.testing.integration.nano.Test.SimpleResponse> responseObserver) { io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.SimpleResponse> responseObserver) {
asyncUnaryCall( asyncUnaryCall(
getChannel().newCall(getUnaryCallMethodHelper(), getCallOptions()), request, responseObserver); getChannel().newCall(getUnaryCallMethodHelper(), getCallOptions()), request, responseObserver);
} }
@ -504,8 +504,8 @@ public final class TestServiceGrpc {
* The server returns the payload with client desired type and sizes. * The server returns the payload with client desired type and sizes.
* </pre> * </pre>
*/ */
public void streamingOutputCall(io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest request, public void streamingOutputCall(io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest request,
io.grpc.stub.StreamObserver<io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse> responseObserver) { io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> responseObserver) {
asyncServerStreamingCall( asyncServerStreamingCall(
getChannel().newCall(getStreamingOutputCallMethodHelper(), getCallOptions()), request, responseObserver); getChannel().newCall(getStreamingOutputCallMethodHelper(), getCallOptions()), request, responseObserver);
} }
@ -516,8 +516,8 @@ public final class TestServiceGrpc {
* The server returns the aggregated size of client payload as the result. * The server returns the aggregated size of client payload as the result.
* </pre> * </pre>
*/ */
public io.grpc.stub.StreamObserver<io.grpc.testing.integration.nano.Test.StreamingInputCallRequest> streamingInputCall( public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest> streamingInputCall(
io.grpc.stub.StreamObserver<io.grpc.testing.integration.nano.Test.StreamingInputCallResponse> responseObserver) { io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse> responseObserver) {
return asyncClientStreamingCall( return asyncClientStreamingCall(
getChannel().newCall(getStreamingInputCallMethodHelper(), getCallOptions()), responseObserver); getChannel().newCall(getStreamingInputCallMethodHelper(), getCallOptions()), responseObserver);
} }
@ -529,8 +529,8 @@ public final class TestServiceGrpc {
* demonstrates the idea of full bidirectionality. * demonstrates the idea of full bidirectionality.
* </pre> * </pre>
*/ */
public io.grpc.stub.StreamObserver<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest> fullBidiCall( public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest> fullBidiCall(
io.grpc.stub.StreamObserver<io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse> responseObserver) { io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> responseObserver) {
return asyncBidiStreamingCall( return asyncBidiStreamingCall(
getChannel().newCall(getFullBidiCallMethodHelper(), getCallOptions()), responseObserver); getChannel().newCall(getFullBidiCallMethodHelper(), getCallOptions()), responseObserver);
} }
@ -543,8 +543,8 @@ public final class TestServiceGrpc {
* first request. * first request.
* </pre> * </pre>
*/ */
public io.grpc.stub.StreamObserver<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest> halfBidiCall( public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest> halfBidiCall(
io.grpc.stub.StreamObserver<io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse> responseObserver) { io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> responseObserver) {
return asyncBidiStreamingCall( return asyncBidiStreamingCall(
getChannel().newCall(getHalfBidiCallMethodHelper(), getCallOptions()), responseObserver); getChannel().newCall(getHalfBidiCallMethodHelper(), getCallOptions()), responseObserver);
} }
@ -555,8 +555,8 @@ public final class TestServiceGrpc {
* method should have a '_' appended. * method should have a '_' appended.
* </pre> * </pre>
*/ */
public io.grpc.stub.StreamObserver<io.grpc.testing.integration.nano.Test.StreamingInputCallRequest> import_( public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest> import_(
io.grpc.stub.StreamObserver<io.grpc.testing.integration.nano.Test.StreamingInputCallResponse> responseObserver) { io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse> responseObserver) {
return asyncBidiStreamingCall( return asyncBidiStreamingCall(
getChannel().newCall(getImportMethodHelper(), getCallOptions()), responseObserver); getChannel().newCall(getImportMethodHelper(), getCallOptions()), responseObserver);
} }
@ -589,7 +589,7 @@ public final class TestServiceGrpc {
* The server returns the client payload as-is. * The server returns the client payload as-is.
* </pre> * </pre>
*/ */
public io.grpc.testing.integration.nano.Test.SimpleResponse unaryCall(io.grpc.testing.integration.nano.Test.SimpleRequest request) { public io.grpc.testing.compiler.nano.Test.SimpleResponse unaryCall(io.grpc.testing.compiler.nano.Test.SimpleRequest request) {
return blockingUnaryCall( return blockingUnaryCall(
getChannel(), getUnaryCallMethodHelper(), getCallOptions(), request); getChannel(), getUnaryCallMethodHelper(), getCallOptions(), request);
} }
@ -600,8 +600,8 @@ public final class TestServiceGrpc {
* The server returns the payload with client desired type and sizes. * The server returns the payload with client desired type and sizes.
* </pre> * </pre>
*/ */
public java.util.Iterator<io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse> streamingOutputCall( public java.util.Iterator<io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> streamingOutputCall(
io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest request) { io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest request) {
return blockingServerStreamingCall( return blockingServerStreamingCall(
getChannel(), getStreamingOutputCallMethodHelper(), getCallOptions(), request); getChannel(), getStreamingOutputCallMethodHelper(), getCallOptions(), request);
} }
@ -634,8 +634,8 @@ public final class TestServiceGrpc {
* The server returns the client payload as-is. * The server returns the client payload as-is.
* </pre> * </pre>
*/ */
public com.google.common.util.concurrent.ListenableFuture<io.grpc.testing.integration.nano.Test.SimpleResponse> unaryCall( public com.google.common.util.concurrent.ListenableFuture<io.grpc.testing.compiler.nano.Test.SimpleResponse> unaryCall(
io.grpc.testing.integration.nano.Test.SimpleRequest request) { io.grpc.testing.compiler.nano.Test.SimpleRequest request) {
return futureUnaryCall( return futureUnaryCall(
getChannel().newCall(getUnaryCallMethodHelper(), getCallOptions()), request); getChannel().newCall(getUnaryCallMethodHelper(), getCallOptions()), request);
} }
@ -666,12 +666,12 @@ public final class TestServiceGrpc {
public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) { public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) {
switch (methodId) { switch (methodId) {
case METHODID_UNARY_CALL: case METHODID_UNARY_CALL:
serviceImpl.unaryCall((io.grpc.testing.integration.nano.Test.SimpleRequest) request, serviceImpl.unaryCall((io.grpc.testing.compiler.nano.Test.SimpleRequest) request,
(io.grpc.stub.StreamObserver<io.grpc.testing.integration.nano.Test.SimpleResponse>) responseObserver); (io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.SimpleResponse>) responseObserver);
break; break;
case METHODID_STREAMING_OUTPUT_CALL: case METHODID_STREAMING_OUTPUT_CALL:
serviceImpl.streamingOutputCall((io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest) request, serviceImpl.streamingOutputCall((io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest) request,
(io.grpc.stub.StreamObserver<io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse>) responseObserver); (io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse>) responseObserver);
break; break;
default: default:
throw new AssertionError(); throw new AssertionError();
@ -685,16 +685,16 @@ public final class TestServiceGrpc {
switch (methodId) { switch (methodId) {
case METHODID_STREAMING_INPUT_CALL: case METHODID_STREAMING_INPUT_CALL:
return (io.grpc.stub.StreamObserver<Req>) serviceImpl.streamingInputCall( return (io.grpc.stub.StreamObserver<Req>) serviceImpl.streamingInputCall(
(io.grpc.stub.StreamObserver<io.grpc.testing.integration.nano.Test.StreamingInputCallResponse>) responseObserver); (io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse>) responseObserver);
case METHODID_FULL_BIDI_CALL: case METHODID_FULL_BIDI_CALL:
return (io.grpc.stub.StreamObserver<Req>) serviceImpl.fullBidiCall( return (io.grpc.stub.StreamObserver<Req>) serviceImpl.fullBidiCall(
(io.grpc.stub.StreamObserver<io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse>) responseObserver); (io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse>) responseObserver);
case METHODID_HALF_BIDI_CALL: case METHODID_HALF_BIDI_CALL:
return (io.grpc.stub.StreamObserver<Req>) serviceImpl.halfBidiCall( return (io.grpc.stub.StreamObserver<Req>) serviceImpl.halfBidiCall(
(io.grpc.stub.StreamObserver<io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse>) responseObserver); (io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse>) responseObserver);
case METHODID_IMPORT: case METHODID_IMPORT:
return (io.grpc.stub.StreamObserver<Req>) serviceImpl.import_( return (io.grpc.stub.StreamObserver<Req>) serviceImpl.import_(
(io.grpc.stub.StreamObserver<io.grpc.testing.integration.nano.Test.StreamingInputCallResponse>) responseObserver); (io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse>) responseObserver);
default: default:
throw new AssertionError(); throw new AssertionError();
} }