() {
- @Override
- public ListSchemasPagedResponse apply(ListSchemasPage input) {
- return new ListSchemasPagedResponse(input);
- }
- },
- MoreExecutors.directExecutor());
+ futurePage, input -> new ListSchemasPagedResponse(input), MoreExecutors.directExecutor());
}
private ListSchemasPagedResponse(ListSchemasPage page) {
diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SchemaServiceSettings.java b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SchemaServiceSettings.java
index eb2d803cd..e8c50371c 100644
--- a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SchemaServiceSettings.java
+++ b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SchemaServiceSettings.java
@@ -217,14 +217,13 @@ public SchemaServiceStubSettings.Builder getStubSettingsBuilder() {
return ((SchemaServiceStubSettings.Builder) getStubSettings());
}
- // NEXT_MAJOR_VER: remove 'throws Exception'
/**
* Applies the given settings updater function to all of the unary API methods in this service.
*
* Note: This method does not support applying settings to streaming methods.
*/
public Builder applyToAllUnaryMethods(
- ApiFunction, Void> settingsUpdater) throws Exception {
+ ApiFunction, Void> settingsUpdater) {
super.applyToAllUnaryMethods(
getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater);
return this;
diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriptionAdminClient.java b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriptionAdminClient.java
index 6cfed5962..6d1c6950a 100644
--- a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriptionAdminClient.java
+++ b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriptionAdminClient.java
@@ -16,7 +16,6 @@
package com.google.cloud.pubsub.v1;
-import com.google.api.core.ApiFunction;
import com.google.api.core.ApiFuture;
import com.google.api.core.ApiFutures;
import com.google.api.core.BetaApi;
@@ -409,13 +408,14 @@ public final Subscription createSubscription(
*
* {@code
* try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
- * ProjectSubscriptionName name = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]");
- * TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]");
+ * String name = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString();
+ * String topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]").toString();
* PushConfig pushConfig = PushConfig.newBuilder().build();
- * int ackDeadlineSeconds = 0;
- * Subscription response = subscriptionAdminClient.createSubscription(name.toString(), topic.toString(), pushConfig, ackDeadlineSeconds);
+ * int ackDeadlineSeconds = 2135351438;
+ * Subscription response =
+ * subscriptionAdminClient.createSubscription(name, topic, pushConfig, ackDeadlineSeconds);
* }
- *
+ * }
*
* @param name Required. The name of the subscription. It must have the format
* `"projects/{project}/subscriptions/{subscription}"`. `{subscription}` must start with a
@@ -651,8 +651,8 @@ public final Subscription getSubscription(ProjectSubscriptionName subscription)
*
* {@code
* try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
- * ProjectSubscriptionName subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]");
- * Subscription response = subscriptionAdminClient.getSubscription(subscription.toString());
+ * String subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString();
+ * Subscription response = subscriptionAdminClient.getSubscription(subscription);
* }
* }
*
@@ -1172,8 +1172,7 @@ public final UnaryCallable modifyAckDeadlineCal
* returned by the Pub/Sub system in the `Pull` response. Must not be empty.
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
- /* package-private */ final void acknowledge(
- ProjectSubscriptionName subscription, List ackIds) {
+ public final void acknowledge(ProjectSubscriptionName subscription, List ackIds) {
AcknowledgeRequest request =
AcknowledgeRequest.newBuilder()
.setSubscription(subscription == null ? null : subscription.toString())
@@ -2373,9 +2372,9 @@ public final UnaryCallable seekCallable() {
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
- * Sets the access control policy on the specified resource. Replaces any existing policy.
+ * Sets the access control policy on the specified resource. Replacesany existing policy.
*
- * Can return `NOT_FOUND`, `INVALID_ARGUMENT`, and `PERMISSION_DENIED` errors.
+ *
Can return `NOT_FOUND`, `INVALID_ARGUMENT`, and `PERMISSION_DENIED`errors.
*
*
Sample code:
*
@@ -2430,9 +2429,9 @@ public final Policy setIamPolicy(String resource, Policy policy) {
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
- * Sets the access control policy on the specified resource. Replaces any existing policy.
+ * Sets the access control policy on the specified resource. Replacesany existing policy.
*
- *
Can return `NOT_FOUND`, `INVALID_ARGUMENT`, and `PERMISSION_DENIED` errors.
+ *
Can return `NOT_FOUND`, `INVALID_ARGUMENT`, and `PERMISSION_DENIED`errors.
*
*
Sample code:
*
@@ -2455,7 +2454,7 @@ public final UnaryCallable setIamPolicyCallable() {
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
- * Gets the access control policy for a resource. Returns an empty policy if the resource exists
+ * Gets the access control policy for a resource. Returns an empty policyif the resource exists
* and does not have a policy set.
*
* Sample code:
@@ -2505,7 +2504,7 @@ public final Policy getIamPolicy(String resource) {
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
- * Gets the access control policy for a resource. Returns an empty policy if the resource exists
+ * Gets the access control policy for a resource. Returns an empty policyif the resource exists
* and does not have a policy set.
*
*
Sample code:
@@ -2529,11 +2528,11 @@ public final UnaryCallable getIamPolicyCallable() {
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
- * Returns permissions that a caller has on the specified resource. If the resource does not
- * exist, this will return an empty set of permissions, not a `NOT_FOUND` error.
+ * Returns permissions that a caller has on the specified resource. If theresource does not exist,
+ * this will return an empty set ofpermissions, not a `NOT_FOUND` error.
*
- * Note: This operation is designed to be used for building permission-aware UIs and
- * command-line tools, not for authorization checking. This operation may "fail open" without
+ *
Note: This operation is designed to be used for buildingpermission-aware UIs and
+ * command-line tools, not for authorizationchecking. This operation may "fail open" without
* warning.
*
*
Sample code:
@@ -2596,11 +2595,11 @@ public final TestIamPermissionsResponse testIamPermissions(
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
- * Returns permissions that a caller has on the specified resource. If the resource does not
- * exist, this will return an empty set of permissions, not a `NOT_FOUND` error.
+ * Returns permissions that a caller has on the specified resource. If theresource does not exist,
+ * this will return an empty set ofpermissions, not a `NOT_FOUND` error.
*
- *
Note: This operation is designed to be used for building permission-aware UIs and
- * command-line tools, not for authorization checking. This operation may "fail open" without
+ *
Note: This operation is designed to be used for buildingpermission-aware UIs and
+ * command-line tools, not for authorizationchecking. This operation may "fail open" without
* warning.
*
*
Sample code:
@@ -2669,12 +2668,7 @@ public static ApiFuture createAsync(
ListSubscriptionsPage.createEmptyPage().createPageAsync(context, futureResponse);
return ApiFutures.transform(
futurePage,
- new ApiFunction() {
- @Override
- public ListSubscriptionsPagedResponse apply(ListSubscriptionsPage input) {
- return new ListSubscriptionsPagedResponse(input);
- }
- },
+ input -> new ListSubscriptionsPagedResponse(input),
MoreExecutors.directExecutor());
}
@@ -2754,12 +2748,7 @@ public static ApiFuture createAsync(
ListSnapshotsPage.createEmptyPage().createPageAsync(context, futureResponse);
return ApiFutures.transform(
futurePage,
- new ApiFunction() {
- @Override
- public ListSnapshotsPagedResponse apply(ListSnapshotsPage input) {
- return new ListSnapshotsPagedResponse(input);
- }
- },
+ input -> new ListSnapshotsPagedResponse(input),
MoreExecutors.directExecutor());
}
diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriptionAdminSettings.java b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriptionAdminSettings.java
index 14cde7756..a90bfd141 100644
--- a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriptionAdminSettings.java
+++ b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriptionAdminSettings.java
@@ -284,14 +284,13 @@ public SubscriberStubSettings.Builder getStubSettingsBuilder() {
return ((SubscriberStubSettings.Builder) getStubSettings());
}
- // NEXT_MAJOR_VER: remove 'throws Exception'
/**
* Applies the given settings updater function to all of the unary API methods in this service.
*
* Note: This method does not support applying settings to streaming methods.
*/
public Builder applyToAllUnaryMethods(
- ApiFunction, Void> settingsUpdater) throws Exception {
+ ApiFunction, Void> settingsUpdater) {
super.applyToAllUnaryMethods(
getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater);
return this;
diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/TopicAdminClient.java b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/TopicAdminClient.java
index 177a3d591..1a9ba2887 100644
--- a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/TopicAdminClient.java
+++ b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/TopicAdminClient.java
@@ -16,7 +16,6 @@
package com.google.cloud.pubsub.v1;
-import com.google.api.core.ApiFunction;
import com.google.api.core.ApiFuture;
import com.google.api.core.ApiFutures;
import com.google.api.core.BetaApi;
@@ -1282,9 +1281,9 @@ public final Policy setIamPolicy(String resource, Policy policy) {
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
- * Sets the access control policy on the specified resource. Replaces any existing policy.
+ * Sets the access control policy on the specified resource. Replacesany existing policy.
*
- * Can return `NOT_FOUND`, `INVALID_ARGUMENT`, and `PERMISSION_DENIED` errors.
+ *
Can return `NOT_FOUND`, `INVALID_ARGUMENT`, and `PERMISSION_DENIED`errors.
*
*
Sample code:
*
@@ -1357,7 +1356,7 @@ public final Policy getIamPolicy(String resource) {
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
- * Gets the access control policy for a resource. Returns an empty policy if the resource exists
+ * Gets the access control policy for a resource. Returns an empty policyif the resource exists
* and does not have a policy set.
*
*
Sample code:
@@ -1381,11 +1380,11 @@ public final UnaryCallable getIamPolicyCallable() {
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
- * Returns permissions that a caller has on the specified resource. If the resource does not
- * exist, this will return an empty set of permissions, not a `NOT_FOUND` error.
+ * Returns permissions that a caller has on the specified resource. If theresource does not exist,
+ * this will return an empty set ofpermissions, not a `NOT_FOUND` error.
*
- * Note: This operation is designed to be used for building permission-aware UIs and
- * command-line tools, not for authorization checking. This operation may "fail open" without
+ *
Note: This operation is designed to be used for buildingpermission-aware UIs and
+ * command-line tools, not for authorizationchecking. This operation may "fail open" without
* warning.
*
*
Sample code:
@@ -1448,11 +1447,11 @@ public final TestIamPermissionsResponse testIamPermissions(
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
- * Returns permissions that a caller has on the specified resource. If the resource does not
- * exist, this will return an empty set of permissions, not a `NOT_FOUND` error.
+ * Returns permissions that a caller has on the specified resource. If theresource does not exist,
+ * this will return an empty set ofpermissions, not a `NOT_FOUND` error.
*
- *
Note: This operation is designed to be used for building permission-aware UIs and
- * command-line tools, not for authorization checking. This operation may "fail open" without
+ *
Note: This operation is designed to be used for buildingpermission-aware UIs and
+ * command-line tools, not for authorizationchecking. This operation may "fail open" without
* warning.
*
*
Sample code:
@@ -1520,14 +1519,7 @@ public static ApiFuture createAsync(
ApiFuture futurePage =
ListTopicsPage.createEmptyPage().createPageAsync(context, futureResponse);
return ApiFutures.transform(
- futurePage,
- new ApiFunction() {
- @Override
- public ListTopicsPagedResponse apply(ListTopicsPage input) {
- return new ListTopicsPagedResponse(input);
- }
- },
- MoreExecutors.directExecutor());
+ futurePage, input -> new ListTopicsPagedResponse(input), MoreExecutors.directExecutor());
}
private ListTopicsPagedResponse(ListTopicsPage page) {
@@ -1601,12 +1593,7 @@ public static ApiFuture createAsync(
ListTopicSubscriptionsPage.createEmptyPage().createPageAsync(context, futureResponse);
return ApiFutures.transform(
futurePage,
- new ApiFunction() {
- @Override
- public ListTopicSubscriptionsPagedResponse apply(ListTopicSubscriptionsPage input) {
- return new ListTopicSubscriptionsPagedResponse(input);
- }
- },
+ input -> new ListTopicSubscriptionsPagedResponse(input),
MoreExecutors.directExecutor());
}
@@ -1730,12 +1717,7 @@ public static ApiFuture createAsync(
ListTopicSnapshotsPage.createEmptyPage().createPageAsync(context, futureResponse);
return ApiFutures.transform(
futurePage,
- new ApiFunction() {
- @Override
- public ListTopicSnapshotsPagedResponse apply(ListTopicSnapshotsPage input) {
- return new ListTopicSnapshotsPagedResponse(input);
- }
- },
+ input -> new ListTopicSnapshotsPagedResponse(input),
MoreExecutors.directExecutor());
}
diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/TopicAdminSettings.java b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/TopicAdminSettings.java
index f67d51094..41ebfd68d 100644
--- a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/TopicAdminSettings.java
+++ b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/TopicAdminSettings.java
@@ -244,14 +244,13 @@ public PublisherStubSettings.Builder getStubSettingsBuilder() {
return ((PublisherStubSettings.Builder) getStubSettings());
}
- // NEXT_MAJOR_VER: remove 'throws Exception'
/**
* Applies the given settings updater function to all of the unary API methods in this service.
*
* Note: This method does not support applying settings to streaming methods.
*/
public Builder applyToAllUnaryMethods(
- ApiFunction, Void> settingsUpdater) throws Exception {
+ ApiFunction, Void> settingsUpdater) {
super.applyToAllUnaryMethods(
getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater);
return this;
diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcPublisherStub.java b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcPublisherStub.java
index 950b72237..5ccb0793e 100644
--- a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcPublisherStub.java
+++ b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcPublisherStub.java
@@ -25,7 +25,6 @@
import com.google.api.gax.grpc.GrpcCallSettings;
import com.google.api.gax.grpc.GrpcStubCallableFactory;
import com.google.api.gax.rpc.ClientContext;
-import com.google.api.gax.rpc.RequestParamsExtractor;
import com.google.api.gax.rpc.UnaryCallable;
import com.google.common.collect.ImmutableMap;
import com.google.iam.v1.GetIamPolicyRequest;
@@ -52,7 +51,6 @@
import io.grpc.MethodDescriptor;
import io.grpc.protobuf.ProtoUtils;
import java.io.IOException;
-import java.util.Map;
import java.util.concurrent.TimeUnit;
import javax.annotation.Generated;
@@ -242,65 +240,50 @@ protected GrpcPublisherStub(
GrpcCallSettings.newBuilder()
.setMethodDescriptor(createTopicMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(Topic request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("name", String.valueOf(request.getName()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("name", String.valueOf(request.getName()));
+ return params.build();
})
.build();
GrpcCallSettings updateTopicTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(updateTopicMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(UpdateTopicRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("topic.name", String.valueOf(request.getTopic().getName()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("topic.name", String.valueOf(request.getTopic().getName()));
+ return params.build();
})
.build();
GrpcCallSettings publishTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(publishMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(PublishRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("topic", String.valueOf(request.getTopic()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("topic", String.valueOf(request.getTopic()));
+ return params.build();
})
.build();
GrpcCallSettings getTopicTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(getTopicMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(GetTopicRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("topic", String.valueOf(request.getTopic()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("topic", String.valueOf(request.getTopic()));
+ return params.build();
})
.build();
GrpcCallSettings listTopicsTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(listTopicsMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(ListTopicsRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("project", String.valueOf(request.getProject()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("project", String.valueOf(request.getProject()));
+ return params.build();
})
.build();
GrpcCallSettings
@@ -309,13 +292,10 @@ public Map extract(ListTopicsRequest request) {
.newBuilder()
.setMethodDescriptor(listTopicSubscriptionsMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(ListTopicSubscriptionsRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("topic", String.valueOf(request.getTopic()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("topic", String.valueOf(request.getTopic()));
+ return params.build();
})
.build();
GrpcCallSettings
@@ -323,26 +303,20 @@ public Map extract(ListTopicSubscriptionsRequest request) {
GrpcCallSettings.newBuilder()
.setMethodDescriptor(listTopicSnapshotsMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(ListTopicSnapshotsRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("topic", String.valueOf(request.getTopic()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("topic", String.valueOf(request.getTopic()));
+ return params.build();
})
.build();
GrpcCallSettings deleteTopicTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(deleteTopicMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(DeleteTopicRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("topic", String.valueOf(request.getTopic()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("topic", String.valueOf(request.getTopic()));
+ return params.build();
})
.build();
GrpcCallSettings
@@ -350,39 +324,30 @@ public Map extract(DeleteTopicRequest request) {
GrpcCallSettings.newBuilder()
.setMethodDescriptor(detachSubscriptionMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(DetachSubscriptionRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("subscription", String.valueOf(request.getSubscription()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("subscription", String.valueOf(request.getSubscription()));
+ return params.build();
})
.build();
GrpcCallSettings setIamPolicyTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(setIamPolicyMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(SetIamPolicyRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("resource", String.valueOf(request.getResource()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("resource", String.valueOf(request.getResource()));
+ return params.build();
})
.build();
GrpcCallSettings getIamPolicyTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(getIamPolicyMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(GetIamPolicyRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("resource", String.valueOf(request.getResource()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("resource", String.valueOf(request.getResource()));
+ return params.build();
})
.build();
GrpcCallSettings
@@ -390,13 +355,10 @@ public Map extract(GetIamPolicyRequest request) {
GrpcCallSettings.newBuilder()
.setMethodDescriptor(testIamPermissionsMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(TestIamPermissionsRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("resource", String.valueOf(request.getResource()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("resource", String.valueOf(request.getResource()));
+ return params.build();
})
.build();
diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcSchemaServiceStub.java b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcSchemaServiceStub.java
index 0ca41b379..e5cd65fb6 100644
--- a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcSchemaServiceStub.java
+++ b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcSchemaServiceStub.java
@@ -23,7 +23,6 @@
import com.google.api.gax.grpc.GrpcCallSettings;
import com.google.api.gax.grpc.GrpcStubCallableFactory;
import com.google.api.gax.rpc.ClientContext;
-import com.google.api.gax.rpc.RequestParamsExtractor;
import com.google.api.gax.rpc.UnaryCallable;
import com.google.common.collect.ImmutableMap;
import com.google.iam.v1.GetIamPolicyRequest;
@@ -46,7 +45,6 @@
import io.grpc.MethodDescriptor;
import io.grpc.protobuf.ProtoUtils;
import java.io.IOException;
-import java.util.Map;
import java.util.concurrent.TimeUnit;
import javax.annotation.Generated;
@@ -201,52 +199,40 @@ protected GrpcSchemaServiceStub(
GrpcCallSettings.newBuilder()
.setMethodDescriptor(createSchemaMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(CreateSchemaRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("parent", String.valueOf(request.getParent()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("parent", String.valueOf(request.getParent()));
+ return params.build();
})
.build();
GrpcCallSettings getSchemaTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(getSchemaMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(GetSchemaRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("name", String.valueOf(request.getName()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("name", String.valueOf(request.getName()));
+ return params.build();
})
.build();
GrpcCallSettings listSchemasTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(listSchemasMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(ListSchemasRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("parent", String.valueOf(request.getParent()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("parent", String.valueOf(request.getParent()));
+ return params.build();
})
.build();
GrpcCallSettings deleteSchemaTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(deleteSchemaMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(DeleteSchemaRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("name", String.valueOf(request.getName()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("name", String.valueOf(request.getName()));
+ return params.build();
})
.build();
GrpcCallSettings
@@ -254,13 +240,10 @@ public Map extract(DeleteSchemaRequest request) {
GrpcCallSettings.newBuilder()
.setMethodDescriptor(validateSchemaMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(ValidateSchemaRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("parent", String.valueOf(request.getParent()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("parent", String.valueOf(request.getParent()));
+ return params.build();
})
.build();
GrpcCallSettings
@@ -268,39 +251,30 @@ public Map extract(ValidateSchemaRequest request) {
GrpcCallSettings.newBuilder()
.setMethodDescriptor(validateMessageMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(ValidateMessageRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("parent", String.valueOf(request.getParent()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("parent", String.valueOf(request.getParent()));
+ return params.build();
})
.build();
GrpcCallSettings setIamPolicyTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(setIamPolicyMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(SetIamPolicyRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("resource", String.valueOf(request.getResource()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("resource", String.valueOf(request.getResource()));
+ return params.build();
})
.build();
GrpcCallSettings getIamPolicyTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(getIamPolicyMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(GetIamPolicyRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("resource", String.valueOf(request.getResource()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("resource", String.valueOf(request.getResource()));
+ return params.build();
})
.build();
GrpcCallSettings
@@ -308,13 +282,10 @@ public Map extract(GetIamPolicyRequest request) {
GrpcCallSettings.newBuilder()
.setMethodDescriptor(testIamPermissionsMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(TestIamPermissionsRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("resource", String.valueOf(request.getResource()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("resource", String.valueOf(request.getResource()));
+ return params.build();
})
.build();
diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcSubscriberStub.java b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcSubscriberStub.java
index 878a2ad7d..523c0376a 100644
--- a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcSubscriberStub.java
+++ b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcSubscriberStub.java
@@ -25,7 +25,6 @@
import com.google.api.gax.grpc.GrpcStubCallableFactory;
import com.google.api.gax.rpc.BidiStreamingCallable;
import com.google.api.gax.rpc.ClientContext;
-import com.google.api.gax.rpc.RequestParamsExtractor;
import com.google.api.gax.rpc.UnaryCallable;
import com.google.common.collect.ImmutableMap;
import com.google.iam.v1.GetIamPolicyRequest;
@@ -60,7 +59,6 @@
import io.grpc.MethodDescriptor;
import io.grpc.protobuf.ProtoUtils;
import java.io.IOException;
-import java.util.Map;
import java.util.concurrent.TimeUnit;
import javax.annotation.Generated;
@@ -326,40 +324,31 @@ protected GrpcSubscriberStub(
GrpcCallSettings.newBuilder()
.setMethodDescriptor(createSubscriptionMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(Subscription request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("name", String.valueOf(request.getName()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("name", String.valueOf(request.getName()));
+ return params.build();
})
.build();
GrpcCallSettings getSubscriptionTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(getSubscriptionMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(GetSubscriptionRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("subscription", String.valueOf(request.getSubscription()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("subscription", String.valueOf(request.getSubscription()));
+ return params.build();
})
.build();
GrpcCallSettings updateSubscriptionTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(updateSubscriptionMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(UpdateSubscriptionRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put(
- "subscription.name", String.valueOf(request.getSubscription().getName()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put(
+ "subscription.name", String.valueOf(request.getSubscription().getName()));
+ return params.build();
})
.build();
GrpcCallSettings
@@ -367,65 +356,50 @@ public Map extract(UpdateSubscriptionRequest request) {
GrpcCallSettings.newBuilder()
.setMethodDescriptor(listSubscriptionsMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(ListSubscriptionsRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("project", String.valueOf(request.getProject()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("project", String.valueOf(request.getProject()));
+ return params.build();
})
.build();
GrpcCallSettings deleteSubscriptionTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(deleteSubscriptionMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(DeleteSubscriptionRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("subscription", String.valueOf(request.getSubscription()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("subscription", String.valueOf(request.getSubscription()));
+ return params.build();
})
.build();
GrpcCallSettings modifyAckDeadlineTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(modifyAckDeadlineMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(ModifyAckDeadlineRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("subscription", String.valueOf(request.getSubscription()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("subscription", String.valueOf(request.getSubscription()));
+ return params.build();
})
.build();
GrpcCallSettings acknowledgeTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(acknowledgeMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(AcknowledgeRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("subscription", String.valueOf(request.getSubscription()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("subscription", String.valueOf(request.getSubscription()));
+ return params.build();
})
.build();
GrpcCallSettings pullTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(pullMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(PullRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("subscription", String.valueOf(request.getSubscription()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("subscription", String.valueOf(request.getSubscription()));
+ return params.build();
})
.build();
GrpcCallSettings streamingPullTransportSettings =
@@ -436,117 +410,90 @@ public Map extract(PullRequest request) {
GrpcCallSettings.newBuilder()
.setMethodDescriptor(modifyPushConfigMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(ModifyPushConfigRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("subscription", String.valueOf(request.getSubscription()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("subscription", String.valueOf(request.getSubscription()));
+ return params.build();
})
.build();
GrpcCallSettings getSnapshotTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(getSnapshotMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(GetSnapshotRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("snapshot", String.valueOf(request.getSnapshot()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("snapshot", String.valueOf(request.getSnapshot()));
+ return params.build();
})
.build();
GrpcCallSettings listSnapshotsTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(listSnapshotsMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(ListSnapshotsRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("project", String.valueOf(request.getProject()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("project", String.valueOf(request.getProject()));
+ return params.build();
})
.build();
GrpcCallSettings createSnapshotTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(createSnapshotMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(CreateSnapshotRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("name", String.valueOf(request.getName()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("name", String.valueOf(request.getName()));
+ return params.build();
})
.build();
GrpcCallSettings updateSnapshotTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(updateSnapshotMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(UpdateSnapshotRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("snapshot.name", String.valueOf(request.getSnapshot().getName()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("snapshot.name", String.valueOf(request.getSnapshot().getName()));
+ return params.build();
})
.build();
GrpcCallSettings deleteSnapshotTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(deleteSnapshotMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(DeleteSnapshotRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("snapshot", String.valueOf(request.getSnapshot()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("snapshot", String.valueOf(request.getSnapshot()));
+ return params.build();
})
.build();
GrpcCallSettings seekTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(seekMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map