@@ -16,13 +16,14 @@
package com .google .pubsub .v1 ;
import static io .grpc .MethodDescriptor .generateFullMethodName ;
import static io .grpc .stub .ClientCalls .asyncUnaryCall ;
import static io .grpc .stub .ClientCalls .blockingUnaryCall ;
import static io .grpc .stub .ClientCalls .futureUnaryCall ;
import static io .grpc .stub .ServerCalls .asyncUnaryCall ;
import static io .grpc .stub .ServerCalls .asyncUnimplementedUnaryCall ;
/** */
/**
*
*
* <pre>
* Service for doing schema-related operations.
* </pre>
*/
@ javax .annotation .Generated (
value = "by gRPC proto compiler" ,
comments = "Source: google/pubsub/v1/schema.proto" )
@@ -319,7 +320,13 @@ public SchemaServiceFutureStub newStub(
return SchemaServiceFutureStub .newStub (factory , channel );
}
/** */
/**
*
*
* <pre>
* Service for doing schema-related operations.
* </pre>
*/
public abstract static class SchemaServiceImplBase implements io .grpc .BindableService {
/**
@@ -332,7 +339,8 @@ public abstract static class SchemaServiceImplBase implements io.grpc.BindableSe
public void createSchema (
com .google .pubsub .v1 .CreateSchemaRequest request ,
io .grpc .stub .StreamObserver <com .google .pubsub .v1 .Schema > responseObserver ) {
asyncUnimplementedUnaryCall (getCreateSchemaMethod (), responseObserver );
io .grpc .stub .ServerCalls .asyncUnimplementedUnaryCall (
getCreateSchemaMethod (), responseObserver );
}
/**
@@ -345,7 +353,7 @@ public void createSchema(
public void getSchema (
com .google .pubsub .v1 .GetSchemaRequest request ,
io .grpc .stub .StreamObserver <com .google .pubsub .v1 .Schema > responseObserver ) {
asyncUnimplementedUnaryCall (getGetSchemaMethod (), responseObserver );
io . grpc . stub . ServerCalls . asyncUnimplementedUnaryCall (getGetSchemaMethod (), responseObserver );
}
/**
@@ -358,7 +366,8 @@ public void getSchema(
public void listSchemas (
com .google .pubsub .v1 .ListSchemasRequest request ,
io .grpc .stub .StreamObserver <com .google .pubsub .v1 .ListSchemasResponse > responseObserver ) {
asyncUnimplementedUnaryCall (getListSchemasMethod (), responseObserver );
io .grpc .stub .ServerCalls .asyncUnimplementedUnaryCall (
getListSchemasMethod (), responseObserver );
}
/**
@@ -371,7 +380,8 @@ public void listSchemas(
public void deleteSchema (
com .google .pubsub .v1 .DeleteSchemaRequest request ,
io .grpc .stub .StreamObserver <com .google .protobuf .Empty > responseObserver ) {
asyncUnimplementedUnaryCall (getDeleteSchemaMethod (), responseObserver );
io .grpc .stub .ServerCalls .asyncUnimplementedUnaryCall (
getDeleteSchemaMethod (), responseObserver );
}
/**
@@ -384,7 +394,8 @@ public void deleteSchema(
public void validateSchema (
com .google .pubsub .v1 .ValidateSchemaRequest request ,
io .grpc .stub .StreamObserver <com .google .pubsub .v1 .ValidateSchemaResponse > responseObserver ) {
asyncUnimplementedUnaryCall (getValidateSchemaMethod (), responseObserver );
io .grpc .stub .ServerCalls .asyncUnimplementedUnaryCall (
getValidateSchemaMethod (), responseObserver );
}
/**
@@ -398,45 +409,46 @@ public void validateMessage(
com .google .pubsub .v1 .ValidateMessageRequest request ,
io .grpc .stub .StreamObserver <com .google .pubsub .v1 .ValidateMessageResponse >
responseObserver ) {
asyncUnimplementedUnaryCall (getValidateMessageMethod (), responseObserver );
io .grpc .stub .ServerCalls .asyncUnimplementedUnaryCall (
getValidateMessageMethod (), responseObserver );
}
@ java .lang .Override
public final io .grpc .ServerServiceDefinition bindService () {
return io .grpc .ServerServiceDefinition .builder (getServiceDescriptor ())
.addMethod (
getCreateSchemaMethod (),
asyncUnaryCall (
io . grpc . stub . ServerCalls . asyncUnaryCall (
new MethodHandlers <
com .google .pubsub .v1 .CreateSchemaRequest , com .google .pubsub .v1 .Schema >(
this , METHODID_CREATE_SCHEMA )))
.addMethod (
getGetSchemaMethod (),
asyncUnaryCall (
io . grpc . stub . ServerCalls . asyncUnaryCall (
new MethodHandlers <
com .google .pubsub .v1 .GetSchemaRequest , com .google .pubsub .v1 .Schema >(
this , METHODID_GET_SCHEMA )))
.addMethod (
getListSchemasMethod (),
asyncUnaryCall (
io . grpc . stub . ServerCalls . asyncUnaryCall (
new MethodHandlers <
com .google .pubsub .v1 .ListSchemasRequest ,
com .google .pubsub .v1 .ListSchemasResponse >(this , METHODID_LIST_SCHEMAS )))
.addMethod (
getDeleteSchemaMethod (),
asyncUnaryCall (
io . grpc . stub . ServerCalls . asyncUnaryCall (
new MethodHandlers <
com .google .pubsub .v1 .DeleteSchemaRequest , com .google .protobuf .Empty >(
this , METHODID_DELETE_SCHEMA )))
.addMethod (
getValidateSchemaMethod (),
asyncUnaryCall (
io . grpc . stub . ServerCalls . asyncUnaryCall (
new MethodHandlers <
com .google .pubsub .v1 .ValidateSchemaRequest ,
com .google .pubsub .v1 .ValidateSchemaResponse >(this , METHODID_VALIDATE_SCHEMA )))
.addMethod (
getValidateMessageMethod (),
asyncUnaryCall (
io . grpc . stub . ServerCalls . asyncUnaryCall (
new MethodHandlers <
com .google .pubsub .v1 .ValidateMessageRequest ,
com .google .pubsub .v1 .ValidateMessageResponse >(
@@ -445,7 +457,13 @@ public final io.grpc.ServerServiceDefinition bindService() {
}
}
/** */
/**
*
*
* <pre>
* Service for doing schema-related operations.
* </pre>
*/
public static final class SchemaServiceStub
extends io .grpc .stub .AbstractAsyncStub <SchemaServiceStub > {
private SchemaServiceStub (io .grpc .Channel channel , io .grpc .CallOptions callOptions ) {
@@ -467,7 +485,7 @@ protected SchemaServiceStub build(io.grpc.Channel channel, io.grpc.CallOptions c
public void createSchema (
com .google .pubsub .v1 .CreateSchemaRequest request ,
io .grpc .stub .StreamObserver <com .google .pubsub .v1 .Schema > responseObserver ) {
asyncUnaryCall (
io . grpc . stub . ClientCalls . asyncUnaryCall (
getChannel ().newCall (getCreateSchemaMethod (), getCallOptions ()),
request ,
responseObserver );
@@ -483,7 +501,7 @@ public void createSchema(
public void getSchema (
com .google .pubsub .v1 .GetSchemaRequest request ,
io .grpc .stub .StreamObserver <com .google .pubsub .v1 .Schema > responseObserver ) {
asyncUnaryCall (
io . grpc . stub . ClientCalls . asyncUnaryCall (
getChannel ().newCall (getGetSchemaMethod (), getCallOptions ()), request , responseObserver );
}
@@ -497,7 +515,7 @@ public void getSchema(
public void listSchemas (
com .google .pubsub .v1 .ListSchemasRequest request ,
io .grpc .stub .StreamObserver <com .google .pubsub .v1 .ListSchemasResponse > responseObserver ) {
asyncUnaryCall (
io . grpc . stub . ClientCalls . asyncUnaryCall (
getChannel ().newCall (getListSchemasMethod (), getCallOptions ()),
request ,
responseObserver );
@@ -513,7 +531,7 @@ public void listSchemas(
public void deleteSchema (
com .google .pubsub .v1 .DeleteSchemaRequest request ,
io .grpc .stub .StreamObserver <com .google .protobuf .Empty > responseObserver ) {
asyncUnaryCall (
io . grpc . stub . ClientCalls . asyncUnaryCall (
getChannel ().newCall (getDeleteSchemaMethod (), getCallOptions ()),
request ,
responseObserver );
@@ -529,7 +547,7 @@ public void deleteSchema(
public void validateSchema (
com .google .pubsub .v1 .ValidateSchemaRequest request ,
io .grpc .stub .StreamObserver <com .google .pubsub .v1 .ValidateSchemaResponse > responseObserver ) {
asyncUnaryCall (
io . grpc . stub . ClientCalls . asyncUnaryCall (
getChannel ().newCall (getValidateSchemaMethod (), getCallOptions ()),
request ,
responseObserver );
@@ -546,14 +564,20 @@ public void validateMessage(
com .google .pubsub .v1 .ValidateMessageRequest request ,
io .grpc .stub .StreamObserver <com .google .pubsub .v1 .ValidateMessageResponse >
responseObserver ) {
asyncUnaryCall (
io . grpc . stub . ClientCalls . asyncUnaryCall (
getChannel ().newCall (getValidateMessageMethod (), getCallOptions ()),
request ,
responseObserver );
}
}
/** */
/**
*
*
* <pre>
* Service for doing schema-related operations.
* </pre>
*/
public static final class SchemaServiceBlockingStub
extends io .grpc .stub .AbstractBlockingStub <SchemaServiceBlockingStub > {
private SchemaServiceBlockingStub (io .grpc .Channel channel , io .grpc .CallOptions callOptions ) {
@@ -575,7 +599,8 @@ protected SchemaServiceBlockingStub build(
*/
public com .google .pubsub .v1 .Schema createSchema (
com .google .pubsub .v1 .CreateSchemaRequest request ) {
return blockingUnaryCall (getChannel (), getCreateSchemaMethod (), getCallOptions (), request );
return io .grpc .stub .ClientCalls .blockingUnaryCall (
getChannel (), getCreateSchemaMethod (), getCallOptions (), request );
}
/**
@@ -586,7 +611,8 @@ public com.google.pubsub.v1.Schema createSchema(
* </pre>
*/
public com .google .pubsub .v1 .Schema getSchema (com .google .pubsub .v1 .GetSchemaRequest request ) {
return blockingUnaryCall (getChannel (), getGetSchemaMethod (), getCallOptions (), request );
return io .grpc .stub .ClientCalls .blockingUnaryCall (
getChannel (), getGetSchemaMethod (), getCallOptions (), request );
}
/**
@@ -598,7 +624,8 @@ public com.google.pubsub.v1.Schema getSchema(com.google.pubsub.v1.GetSchemaReque
*/
public com .google .pubsub .v1 .ListSchemasResponse listSchemas (
com .google .pubsub .v1 .ListSchemasRequest request ) {
return blockingUnaryCall (getChannel (), getListSchemasMethod (), getCallOptions (), request );
return io .grpc .stub .ClientCalls .blockingUnaryCall (
getChannel (), getListSchemasMethod (), getCallOptions (), request );
}
/**
@@ -610,7 +637,8 @@ public com.google.pubsub.v1.ListSchemasResponse listSchemas(
*/
public com .google .protobuf .Empty deleteSchema (
com .google .pubsub .v1 .DeleteSchemaRequest request ) {
return blockingUnaryCall (getChannel (), getDeleteSchemaMethod (), getCallOptions (), request );
return io .grpc .stub .ClientCalls .blockingUnaryCall (
getChannel (), getDeleteSchemaMethod (), getCallOptions (), request );
}
/**
@@ -622,7 +650,8 @@ public com.google.protobuf.Empty deleteSchema(
*/
public com .google .pubsub .v1 .ValidateSchemaResponse validateSchema (
com .google .pubsub .v1 .ValidateSchemaRequest request ) {
return blockingUnaryCall (getChannel (), getValidateSchemaMethod (), getCallOptions (), request );
return io .grpc .stub .ClientCalls .blockingUnaryCall (
getChannel (), getValidateSchemaMethod (), getCallOptions (), request );
}
/**
@@ -634,11 +663,18 @@ public com.google.pubsub.v1.ValidateSchemaResponse validateSchema(
*/
public com .google .pubsub .v1 .ValidateMessageResponse validateMessage (
com .google .pubsub .v1 .ValidateMessageRequest request ) {
return blockingUnaryCall (getChannel (), getValidateMessageMethod (), getCallOptions (), request );
return io .grpc .stub .ClientCalls .blockingUnaryCall (
getChannel (), getValidateMessageMethod (), getCallOptions (), request );
}
}
/** */
/**
*
*
* <pre>
* Service for doing schema-related operations.
* </pre>
*/
public static final class SchemaServiceFutureStub
extends io .grpc .stub .AbstractFutureStub <SchemaServiceFutureStub > {
private SchemaServiceFutureStub (io .grpc .Channel channel , io .grpc .CallOptions callOptions ) {
@@ -660,7 +696,7 @@ protected SchemaServiceFutureStub build(
*/
public com .google .common .util .concurrent .ListenableFuture <com .google .pubsub .v1 .Schema >
createSchema (com .google .pubsub .v1 .CreateSchemaRequest request ) {
return futureUnaryCall (
return io . grpc . stub . ClientCalls . futureUnaryCall (
getChannel ().newCall (getCreateSchemaMethod (), getCallOptions ()), request );
}
@@ -673,7 +709,8 @@ protected SchemaServiceFutureStub build(
*/
public com .google .common .util .concurrent .ListenableFuture <com .google .pubsub .v1 .Schema >
getSchema (com .google .pubsub .v1 .GetSchemaRequest request ) {
return futureUnaryCall (getChannel ().newCall (getGetSchemaMethod (), getCallOptions ()), request );
return io .grpc .stub .ClientCalls .futureUnaryCall (
getChannel ().newCall (getGetSchemaMethod (), getCallOptions ()), request );
}
/**
@@ -686,7 +723,7 @@ protected SchemaServiceFutureStub build(
public com .google .common .util .concurrent .ListenableFuture <
com .google .pubsub .v1 .ListSchemasResponse >
listSchemas (com .google .pubsub .v1 .ListSchemasRequest request ) {
return futureUnaryCall (
return io . grpc . stub . ClientCalls . futureUnaryCall (
getChannel ().newCall (getListSchemasMethod (), getCallOptions ()), request );
}
@@ -699,7 +736,7 @@ protected SchemaServiceFutureStub build(
*/
public com .google .common .util .concurrent .ListenableFuture <com .google .protobuf .Empty >
deleteSchema (com .google .pubsub .v1 .DeleteSchemaRequest request ) {
return futureUnaryCall (
return io . grpc . stub . ClientCalls . futureUnaryCall (
getChannel ().newCall (getDeleteSchemaMethod (), getCallOptions ()), request );
}
@@ -713,7 +750,7 @@ protected SchemaServiceFutureStub build(
public com .google .common .util .concurrent .ListenableFuture <
com .google .pubsub .v1 .ValidateSchemaResponse >
validateSchema (com .google .pubsub .v1 .ValidateSchemaRequest request ) {
return futureUnaryCall (
return io . grpc . stub . ClientCalls . futureUnaryCall (
getChannel ().newCall (getValidateSchemaMethod (), getCallOptions ()), request );
}
@@ -727,7 +764,7 @@ protected SchemaServiceFutureStub build(
public com .google .common .util .concurrent .ListenableFuture <
com .google .pubsub .v1 .ValidateMessageResponse >
validateMessage (com .google .pubsub .v1 .ValidateMessageRequest request ) {
return futureUnaryCall (
return io . grpc . stub . ClientCalls . futureUnaryCall (
getChannel ().newCall (getValidateMessageMethod (), getCallOptions ()), request );
}
}