diff --git a/grpc-google-cloud-workflow-executions-v1beta/src/main/java/com/google/cloud/workflows/executions/v1beta/ExecutionsGrpc.java b/grpc-google-cloud-workflow-executions-v1beta/src/main/java/com/google/cloud/workflows/executions/v1beta/ExecutionsGrpc.java index 5802eaf4..64cef090 100644 --- a/grpc-google-cloud-workflow-executions-v1beta/src/main/java/com/google/cloud/workflows/executions/v1beta/ExecutionsGrpc.java +++ b/grpc-google-cloud-workflow-executions-v1beta/src/main/java/com/google/cloud/workflows/executions/v1beta/ExecutionsGrpc.java @@ -16,11 +16,6 @@ package com.google.cloud.workflows.executions.v1beta; 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; /** * @@ -291,7 +286,8 @@ public void listExecutions( io.grpc.stub.StreamObserver< com.google.cloud.workflows.executions.v1beta.ListExecutionsResponse> responseObserver) { - asyncUnimplementedUnaryCall(getListExecutionsMethod(), responseObserver); + io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( + getListExecutionsMethod(), responseObserver); } /** @@ -305,7 +301,8 @@ public void createExecution( com.google.cloud.workflows.executions.v1beta.CreateExecutionRequest request, io.grpc.stub.StreamObserver responseObserver) { - asyncUnimplementedUnaryCall(getCreateExecutionMethod(), responseObserver); + io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( + getCreateExecutionMethod(), responseObserver); } /** @@ -319,7 +316,8 @@ public void getExecution( com.google.cloud.workflows.executions.v1beta.GetExecutionRequest request, io.grpc.stub.StreamObserver responseObserver) { - asyncUnimplementedUnaryCall(getGetExecutionMethod(), responseObserver); + io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( + getGetExecutionMethod(), responseObserver); } /** @@ -333,7 +331,8 @@ public void cancelExecution( com.google.cloud.workflows.executions.v1beta.CancelExecutionRequest request, io.grpc.stub.StreamObserver responseObserver) { - asyncUnimplementedUnaryCall(getCancelExecutionMethod(), responseObserver); + io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( + getCancelExecutionMethod(), responseObserver); } @java.lang.Override @@ -341,28 +340,28 @@ public final io.grpc.ServerServiceDefinition bindService() { return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor()) .addMethod( getListExecutionsMethod(), - asyncUnaryCall( + io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< com.google.cloud.workflows.executions.v1beta.ListExecutionsRequest, com.google.cloud.workflows.executions.v1beta.ListExecutionsResponse>( this, METHODID_LIST_EXECUTIONS))) .addMethod( getCreateExecutionMethod(), - asyncUnaryCall( + io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< com.google.cloud.workflows.executions.v1beta.CreateExecutionRequest, com.google.cloud.workflows.executions.v1beta.Execution>( this, METHODID_CREATE_EXECUTION))) .addMethod( getGetExecutionMethod(), - asyncUnaryCall( + io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< com.google.cloud.workflows.executions.v1beta.GetExecutionRequest, com.google.cloud.workflows.executions.v1beta.Execution>( this, METHODID_GET_EXECUTION))) .addMethod( getCancelExecutionMethod(), - asyncUnaryCall( + io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< com.google.cloud.workflows.executions.v1beta.CancelExecutionRequest, com.google.cloud.workflows.executions.v1beta.Execution>( @@ -404,7 +403,7 @@ public void listExecutions( io.grpc.stub.StreamObserver< com.google.cloud.workflows.executions.v1beta.ListExecutionsResponse> responseObserver) { - asyncUnaryCall( + io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getListExecutionsMethod(), getCallOptions()), request, responseObserver); @@ -421,7 +420,7 @@ public void createExecution( com.google.cloud.workflows.executions.v1beta.CreateExecutionRequest request, io.grpc.stub.StreamObserver responseObserver) { - asyncUnaryCall( + io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getCreateExecutionMethod(), getCallOptions()), request, responseObserver); @@ -438,7 +437,7 @@ public void getExecution( com.google.cloud.workflows.executions.v1beta.GetExecutionRequest request, io.grpc.stub.StreamObserver responseObserver) { - asyncUnaryCall( + io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getGetExecutionMethod(), getCallOptions()), request, responseObserver); @@ -455,7 +454,7 @@ public void cancelExecution( com.google.cloud.workflows.executions.v1beta.CancelExecutionRequest request, io.grpc.stub.StreamObserver responseObserver) { - asyncUnaryCall( + io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getCancelExecutionMethod(), getCallOptions()), request, responseObserver); @@ -494,7 +493,8 @@ protected ExecutionsBlockingStub build( */ public com.google.cloud.workflows.executions.v1beta.ListExecutionsResponse listExecutions( com.google.cloud.workflows.executions.v1beta.ListExecutionsRequest request) { - return blockingUnaryCall(getChannel(), getListExecutionsMethod(), getCallOptions(), request); + return io.grpc.stub.ClientCalls.blockingUnaryCall( + getChannel(), getListExecutionsMethod(), getCallOptions(), request); } /** @@ -506,7 +506,8 @@ public com.google.cloud.workflows.executions.v1beta.ListExecutionsResponse listE */ public com.google.cloud.workflows.executions.v1beta.Execution createExecution( com.google.cloud.workflows.executions.v1beta.CreateExecutionRequest request) { - return blockingUnaryCall(getChannel(), getCreateExecutionMethod(), getCallOptions(), request); + return io.grpc.stub.ClientCalls.blockingUnaryCall( + getChannel(), getCreateExecutionMethod(), getCallOptions(), request); } /** @@ -518,7 +519,8 @@ public com.google.cloud.workflows.executions.v1beta.Execution createExecution( */ public com.google.cloud.workflows.executions.v1beta.Execution getExecution( com.google.cloud.workflows.executions.v1beta.GetExecutionRequest request) { - return blockingUnaryCall(getChannel(), getGetExecutionMethod(), getCallOptions(), request); + return io.grpc.stub.ClientCalls.blockingUnaryCall( + getChannel(), getGetExecutionMethod(), getCallOptions(), request); } /** @@ -530,7 +532,8 @@ public com.google.cloud.workflows.executions.v1beta.Execution getExecution( */ public com.google.cloud.workflows.executions.v1beta.Execution cancelExecution( com.google.cloud.workflows.executions.v1beta.CancelExecutionRequest request) { - return blockingUnaryCall(getChannel(), getCancelExecutionMethod(), getCallOptions(), request); + return io.grpc.stub.ClientCalls.blockingUnaryCall( + getChannel(), getCancelExecutionMethod(), getCallOptions(), request); } } @@ -566,7 +569,7 @@ protected ExecutionsFutureStub build(io.grpc.Channel channel, io.grpc.CallOption public com.google.common.util.concurrent.ListenableFuture< com.google.cloud.workflows.executions.v1beta.ListExecutionsResponse> listExecutions(com.google.cloud.workflows.executions.v1beta.ListExecutionsRequest request) { - return futureUnaryCall( + return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getListExecutionsMethod(), getCallOptions()), request); } @@ -581,7 +584,7 @@ protected ExecutionsFutureStub build(io.grpc.Channel channel, io.grpc.CallOption com.google.cloud.workflows.executions.v1beta.Execution> createExecution( com.google.cloud.workflows.executions.v1beta.CreateExecutionRequest request) { - return futureUnaryCall( + return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getCreateExecutionMethod(), getCallOptions()), request); } @@ -595,7 +598,7 @@ protected ExecutionsFutureStub build(io.grpc.Channel channel, io.grpc.CallOption public com.google.common.util.concurrent.ListenableFuture< com.google.cloud.workflows.executions.v1beta.Execution> getExecution(com.google.cloud.workflows.executions.v1beta.GetExecutionRequest request) { - return futureUnaryCall( + return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getGetExecutionMethod(), getCallOptions()), request); } @@ -610,7 +613,7 @@ protected ExecutionsFutureStub build(io.grpc.Channel channel, io.grpc.CallOption com.google.cloud.workflows.executions.v1beta.Execution> cancelExecution( com.google.cloud.workflows.executions.v1beta.CancelExecutionRequest request) { - return futureUnaryCall( + return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getCancelExecutionMethod(), getCallOptions()), request); } } diff --git a/synth.metadata b/synth.metadata index 9c98b2fb..c1746d7d 100644 --- a/synth.metadata +++ b/synth.metadata @@ -4,15 +4,15 @@ "git": { "name": ".", "remote": "https://github.com/googleapis/java-workflow-executions.git", - "sha": "16c56036867e723b1f4857f5c34949a6670bee42" + "sha": "4ae9db293e8c08e0c568665ea844d2243beb70dd" } }, { "git": { "name": "googleapis", "remote": "https://github.com/googleapis/googleapis.git", - "sha": "3befd26ca55723d3e8111909331eac1249837987", - "internalRef": "360805639" + "sha": "0e915217fb5261c1e57bfaf0e16ee5c7feaaba89", + "internalRef": "361377784" } }, {