diff --git a/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1alpha1/DatastreamClient.java b/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1alpha1/DatastreamClient.java
index c8048f8d..4babda3a 100644
--- a/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1alpha1/DatastreamClient.java
+++ b/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1alpha1/DatastreamClient.java
@@ -16,7 +16,6 @@
 
 package com.google.cloud.datastream.v1alpha1;
 
-import com.google.api.core.ApiFunction;
 import com.google.api.core.ApiFuture;
 import com.google.api.core.ApiFutures;
 import com.google.api.core.BetaApi;
@@ -2802,12 +2801,7 @@ public static ApiFuture<ListConnectionProfilesPagedResponse> createAsync(
           ListConnectionProfilesPage.createEmptyPage().createPageAsync(context, futureResponse);
       return ApiFutures.transform(
           futurePage,
-          new ApiFunction<ListConnectionProfilesPage, ListConnectionProfilesPagedResponse>() {
-            @Override
-            public ListConnectionProfilesPagedResponse apply(ListConnectionProfilesPage input) {
-              return new ListConnectionProfilesPagedResponse(input);
-            }
-          },
+          input -> new ListConnectionProfilesPagedResponse(input),
           MoreExecutors.directExecutor());
     }
 
@@ -2892,14 +2886,7 @@ public static ApiFuture<ListStreamsPagedResponse> createAsync(
       ApiFuture<ListStreamsPage> futurePage =
           ListStreamsPage.createEmptyPage().createPageAsync(context, futureResponse);
       return ApiFutures.transform(
-          futurePage,
-          new ApiFunction<ListStreamsPage, ListStreamsPagedResponse>() {
-            @Override
-            public ListStreamsPagedResponse apply(ListStreamsPage input) {
-              return new ListStreamsPagedResponse(input);
-            }
-          },
-          MoreExecutors.directExecutor());
+          futurePage, input -> new ListStreamsPagedResponse(input), MoreExecutors.directExecutor());
     }
 
     private ListStreamsPagedResponse(ListStreamsPage page) {
@@ -2973,12 +2960,7 @@ public static ApiFuture<FetchStaticIpsPagedResponse> createAsync(
           FetchStaticIpsPage.createEmptyPage().createPageAsync(context, futureResponse);
       return ApiFutures.transform(
           futurePage,
-          new ApiFunction<FetchStaticIpsPage, FetchStaticIpsPagedResponse>() {
-            @Override
-            public FetchStaticIpsPagedResponse apply(FetchStaticIpsPage input) {
-              return new FetchStaticIpsPagedResponse(input);
-            }
-          },
+          input -> new FetchStaticIpsPagedResponse(input),
           MoreExecutors.directExecutor());
     }
 
@@ -3056,12 +3038,7 @@ public static ApiFuture<ListPrivateConnectionsPagedResponse> createAsync(
           ListPrivateConnectionsPage.createEmptyPage().createPageAsync(context, futureResponse);
       return ApiFutures.transform(
           futurePage,
-          new ApiFunction<ListPrivateConnectionsPage, ListPrivateConnectionsPagedResponse>() {
-            @Override
-            public ListPrivateConnectionsPagedResponse apply(ListPrivateConnectionsPage input) {
-              return new ListPrivateConnectionsPagedResponse(input);
-            }
-          },
+          input -> new ListPrivateConnectionsPagedResponse(input),
           MoreExecutors.directExecutor());
     }
 
@@ -3146,14 +3123,7 @@ public static ApiFuture<ListRoutesPagedResponse> createAsync(
       ApiFuture<ListRoutesPage> futurePage =
           ListRoutesPage.createEmptyPage().createPageAsync(context, futureResponse);
       return ApiFutures.transform(
-          futurePage,
-          new ApiFunction<ListRoutesPage, ListRoutesPagedResponse>() {
-            @Override
-            public ListRoutesPagedResponse apply(ListRoutesPage input) {
-              return new ListRoutesPagedResponse(input);
-            }
-          },
-          MoreExecutors.directExecutor());
+          futurePage, input -> new ListRoutesPagedResponse(input), MoreExecutors.directExecutor());
     }
 
     private ListRoutesPagedResponse(ListRoutesPage page) {
diff --git a/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1alpha1/DatastreamSettings.java b/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1alpha1/DatastreamSettings.java
index ef9d9a9a..17b71807 100644
--- a/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1alpha1/DatastreamSettings.java
+++ b/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1alpha1/DatastreamSettings.java
@@ -351,14 +351,13 @@ public DatastreamStubSettings.Builder getStubSettingsBuilder() {
       return ((DatastreamStubSettings.Builder) getStubSettings());
     }
 
-    // NEXT_MAJOR_VER: remove 'throws Exception'.
     /**
      * Applies the given settings updater function to all of the unary API methods in this service.
      *
      * <p>Note: This method does not support applying settings to streaming methods.
      */
     public Builder applyToAllUnaryMethods(
-        ApiFunction<UnaryCallSettings.Builder<?, ?>, Void> settingsUpdater) throws Exception {
+        ApiFunction<UnaryCallSettings.Builder<?, ?>, Void> settingsUpdater) {
       super.applyToAllUnaryMethods(
           getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater);
       return this;
diff --git a/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1alpha1/stub/DatastreamStubSettings.java b/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1alpha1/stub/DatastreamStubSettings.java
index 920fb722..54f0b03f 100644
--- a/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1alpha1/stub/DatastreamStubSettings.java
+++ b/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1alpha1/stub/DatastreamStubSettings.java
@@ -1435,14 +1435,13 @@ private static Builder initDefaults(Builder builder) {
       return builder;
     }
 
-    // NEXT_MAJOR_VER: remove 'throws Exception'.
     /**
      * Applies the given settings updater function to all of the unary API methods in this service.
      *
      * <p>Note: This method does not support applying settings to streaming methods.
      */
     public Builder applyToAllUnaryMethods(
-        ApiFunction<UnaryCallSettings.Builder<?, ?>, Void> settingsUpdater) throws Exception {
+        ApiFunction<UnaryCallSettings.Builder<?, ?>, Void> settingsUpdater) {
       super.applyToAllUnaryMethods(unaryMethodSettingsBuilders, settingsUpdater);
       return this;
     }
diff --git a/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1alpha1/stub/GrpcDatastreamStub.java b/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1alpha1/stub/GrpcDatastreamStub.java
index 62687745..4e95111f 100644
--- a/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1alpha1/stub/GrpcDatastreamStub.java
+++ b/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1alpha1/stub/GrpcDatastreamStub.java
@@ -29,7 +29,6 @@
 import com.google.api.gax.grpc.GrpcStubCallableFactory;
 import com.google.api.gax.rpc.ClientContext;
 import com.google.api.gax.rpc.OperationCallable;
-import com.google.api.gax.rpc.RequestParamsExtractor;
 import com.google.api.gax.rpc.UnaryCallable;
 import com.google.cloud.datastream.v1alpha1.ConnectionProfile;
 import com.google.cloud.datastream.v1alpha1.CreateConnectionProfileRequest;
@@ -71,7 +70,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;
 
@@ -412,13 +410,10 @@ protected GrpcDatastreamStub(
                 .<ListConnectionProfilesRequest, ListConnectionProfilesResponse>newBuilder()
                 .setMethodDescriptor(listConnectionProfilesMethodDescriptor)
                 .setParamsExtractor(
-                    new RequestParamsExtractor<ListConnectionProfilesRequest>() {
-                      @Override
-                      public Map<String, String> extract(ListConnectionProfilesRequest request) {
-                        ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
-                        params.put("parent", String.valueOf(request.getParent()));
-                        return params.build();
-                      }
+                    request -> {
+                      ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                      params.put("parent", String.valueOf(request.getParent()));
+                      return params.build();
                     })
                 .build();
     GrpcCallSettings<GetConnectionProfileRequest, ConnectionProfile>
@@ -426,13 +421,10 @@ public Map<String, String> extract(ListConnectionProfilesRequest request) {
             GrpcCallSettings.<GetConnectionProfileRequest, ConnectionProfile>newBuilder()
                 .setMethodDescriptor(getConnectionProfileMethodDescriptor)
                 .setParamsExtractor(
-                    new RequestParamsExtractor<GetConnectionProfileRequest>() {
-                      @Override
-                      public Map<String, String> extract(GetConnectionProfileRequest request) {
-                        ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
-                        params.put("name", String.valueOf(request.getName()));
-                        return params.build();
-                      }
+                    request -> {
+                      ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                      params.put("name", String.valueOf(request.getName()));
+                      return params.build();
                     })
                 .build();
     GrpcCallSettings<CreateConnectionProfileRequest, Operation>
@@ -440,13 +432,10 @@ public Map<String, String> extract(GetConnectionProfileRequest request) {
             GrpcCallSettings.<CreateConnectionProfileRequest, Operation>newBuilder()
                 .setMethodDescriptor(createConnectionProfileMethodDescriptor)
                 .setParamsExtractor(
-                    new RequestParamsExtractor<CreateConnectionProfileRequest>() {
-                      @Override
-                      public Map<String, String> extract(CreateConnectionProfileRequest request) {
-                        ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
-                        params.put("parent", String.valueOf(request.getParent()));
-                        return params.build();
-                      }
+                    request -> {
+                      ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                      params.put("parent", String.valueOf(request.getParent()));
+                      return params.build();
                     })
                 .build();
     GrpcCallSettings<UpdateConnectionProfileRequest, Operation>
@@ -454,15 +443,12 @@ public Map<String, String> extract(CreateConnectionProfileRequest request) {
             GrpcCallSettings.<UpdateConnectionProfileRequest, Operation>newBuilder()
                 .setMethodDescriptor(updateConnectionProfileMethodDescriptor)
                 .setParamsExtractor(
-                    new RequestParamsExtractor<UpdateConnectionProfileRequest>() {
-                      @Override
-                      public Map<String, String> extract(UpdateConnectionProfileRequest request) {
-                        ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
-                        params.put(
-                            "connection_profile.name",
-                            String.valueOf(request.getConnectionProfile().getName()));
-                        return params.build();
-                      }
+                    request -> {
+                      ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                      params.put(
+                          "connection_profile.name",
+                          String.valueOf(request.getConnectionProfile().getName()));
+                      return params.build();
                     })
                 .build();
     GrpcCallSettings<DeleteConnectionProfileRequest, Operation>
@@ -470,13 +456,10 @@ public Map<String, String> extract(UpdateConnectionProfileRequest request) {
             GrpcCallSettings.<DeleteConnectionProfileRequest, Operation>newBuilder()
                 .setMethodDescriptor(deleteConnectionProfileMethodDescriptor)
                 .setParamsExtractor(
-                    new RequestParamsExtractor<DeleteConnectionProfileRequest>() {
-                      @Override
-                      public Map<String, String> extract(DeleteConnectionProfileRequest request) {
-                        ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
-                        params.put("name", String.valueOf(request.getName()));
-                        return params.build();
-                      }
+                    request -> {
+                      ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                      params.put("name", String.valueOf(request.getName()));
+                      return params.build();
                     })
                 .build();
     GrpcCallSettings<DiscoverConnectionProfileRequest, DiscoverConnectionProfileResponse>
@@ -485,91 +468,70 @@ public Map<String, String> extract(DeleteConnectionProfileRequest request) {
                 .<DiscoverConnectionProfileRequest, DiscoverConnectionProfileResponse>newBuilder()
                 .setMethodDescriptor(discoverConnectionProfileMethodDescriptor)
                 .setParamsExtractor(
-                    new RequestParamsExtractor<DiscoverConnectionProfileRequest>() {
-                      @Override
-                      public Map<String, String> extract(DiscoverConnectionProfileRequest request) {
-                        ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
-                        params.put("parent", String.valueOf(request.getParent()));
-                        return params.build();
-                      }
+                    request -> {
+                      ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                      params.put("parent", String.valueOf(request.getParent()));
+                      return params.build();
                     })
                 .build();
     GrpcCallSettings<ListStreamsRequest, ListStreamsResponse> listStreamsTransportSettings =
         GrpcCallSettings.<ListStreamsRequest, ListStreamsResponse>newBuilder()
             .setMethodDescriptor(listStreamsMethodDescriptor)
             .setParamsExtractor(
-                new RequestParamsExtractor<ListStreamsRequest>() {
-                  @Override
-                  public Map<String, String> extract(ListStreamsRequest request) {
-                    ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
-                    params.put("parent", String.valueOf(request.getParent()));
-                    return params.build();
-                  }
+                request -> {
+                  ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                  params.put("parent", String.valueOf(request.getParent()));
+                  return params.build();
                 })
             .build();
     GrpcCallSettings<GetStreamRequest, Stream> getStreamTransportSettings =
         GrpcCallSettings.<GetStreamRequest, Stream>newBuilder()
             .setMethodDescriptor(getStreamMethodDescriptor)
             .setParamsExtractor(
-                new RequestParamsExtractor<GetStreamRequest>() {
-                  @Override
-                  public Map<String, String> extract(GetStreamRequest request) {
-                    ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
-                    params.put("name", String.valueOf(request.getName()));
-                    return params.build();
-                  }
+                request -> {
+                  ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                  params.put("name", String.valueOf(request.getName()));
+                  return params.build();
                 })
             .build();
     GrpcCallSettings<CreateStreamRequest, Operation> createStreamTransportSettings =
         GrpcCallSettings.<CreateStreamRequest, Operation>newBuilder()
             .setMethodDescriptor(createStreamMethodDescriptor)
             .setParamsExtractor(
-                new RequestParamsExtractor<CreateStreamRequest>() {
-                  @Override
-                  public Map<String, String> extract(CreateStreamRequest request) {
-                    ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
-                    params.put("parent", String.valueOf(request.getParent()));
-                    return params.build();
-                  }
+                request -> {
+                  ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                  params.put("parent", String.valueOf(request.getParent()));
+                  return params.build();
                 })
             .build();
     GrpcCallSettings<UpdateStreamRequest, Operation> updateStreamTransportSettings =
         GrpcCallSettings.<UpdateStreamRequest, Operation>newBuilder()
             .setMethodDescriptor(updateStreamMethodDescriptor)
             .setParamsExtractor(
-                new RequestParamsExtractor<UpdateStreamRequest>() {
-                  @Override
-                  public Map<String, String> extract(UpdateStreamRequest request) {
-                    ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
-                    params.put("stream.name", String.valueOf(request.getStream().getName()));
-                    return params.build();
-                  }
+                request -> {
+                  ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                  params.put("stream.name", String.valueOf(request.getStream().getName()));
+                  return params.build();
                 })
             .build();
     GrpcCallSettings<DeleteStreamRequest, Operation> deleteStreamTransportSettings =
         GrpcCallSettings.<DeleteStreamRequest, Operation>newBuilder()
             .setMethodDescriptor(deleteStreamMethodDescriptor)
             .setParamsExtractor(
-                new RequestParamsExtractor<DeleteStreamRequest>() {
-                  @Override
-                  public Map<String, String> extract(DeleteStreamRequest request) {
-                    ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
-                    params.put("name", String.valueOf(request.getName()));
-                    return params.build();
-                  }
+                request -> {
+                  ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                  params.put("name", String.valueOf(request.getName()));
+                  return params.build();
                 })
             .build();
     GrpcCallSettings<FetchErrorsRequest, Operation> fetchErrorsTransportSettings =
         GrpcCallSettings.<FetchErrorsRequest, Operation>newBuilder()
             .setMethodDescriptor(fetchErrorsMethodDescriptor)
             .setParamsExtractor(
-                new RequestParamsExtractor<FetchErrorsRequest>() {
-                  @Override
-                  public Map<String, String> extract(FetchErrorsRequest request) {
-                    ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
-                    params.put("stream", String.valueOf(request.getStream()));
-                    return params.build();
-                  }
+                request -> {
+                  ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                  params.put("stream", String.valueOf(request.getStream()));
+                  return params.build();
                 })
             .build();
     GrpcCallSettings<FetchStaticIpsRequest, FetchStaticIpsResponse>
@@ -577,13 +539,10 @@ public Map<String, String> extract(FetchErrorsRequest request) {
             GrpcCallSettings.<FetchStaticIpsRequest, FetchStaticIpsResponse>newBuilder()
                 .setMethodDescriptor(fetchStaticIpsMethodDescriptor)
                 .setParamsExtractor(
-                    new RequestParamsExtractor<FetchStaticIpsRequest>() {
-                      @Override
-                      public Map<String, String> extract(FetchStaticIpsRequest request) {
-                        ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
-                        params.put("name", String.valueOf(request.getName()));
-                        return params.build();
-                      }
+                    request -> {
+                      ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                      params.put("name", String.valueOf(request.getName()));
+                      return params.build();
                     })
                 .build();
     GrpcCallSettings<CreatePrivateConnectionRequest, Operation>
@@ -591,13 +550,10 @@ public Map<String, String> extract(FetchStaticIpsRequest request) {
             GrpcCallSettings.<CreatePrivateConnectionRequest, Operation>newBuilder()
                 .setMethodDescriptor(createPrivateConnectionMethodDescriptor)
                 .setParamsExtractor(
-                    new RequestParamsExtractor<CreatePrivateConnectionRequest>() {
-                      @Override
-                      public Map<String, String> extract(CreatePrivateConnectionRequest request) {
-                        ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
-                        params.put("parent", String.valueOf(request.getParent()));
-                        return params.build();
-                      }
+                    request -> {
+                      ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                      params.put("parent", String.valueOf(request.getParent()));
+                      return params.build();
                     })
                 .build();
     GrpcCallSettings<GetPrivateConnectionRequest, PrivateConnection>
@@ -605,13 +561,10 @@ public Map<String, String> extract(CreatePrivateConnectionRequest request) {
             GrpcCallSettings.<GetPrivateConnectionRequest, PrivateConnection>newBuilder()
                 .setMethodDescriptor(getPrivateConnectionMethodDescriptor)
                 .setParamsExtractor(
-                    new RequestParamsExtractor<GetPrivateConnectionRequest>() {
-                      @Override
-                      public Map<String, String> extract(GetPrivateConnectionRequest request) {
-                        ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
-                        params.put("name", String.valueOf(request.getName()));
-                        return params.build();
-                      }
+                    request -> {
+                      ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                      params.put("name", String.valueOf(request.getName()));
+                      return params.build();
                     })
                 .build();
     GrpcCallSettings<ListPrivateConnectionsRequest, ListPrivateConnectionsResponse>
@@ -620,13 +573,10 @@ public Map<String, String> extract(GetPrivateConnectionRequest request) {
                 .<ListPrivateConnectionsRequest, ListPrivateConnectionsResponse>newBuilder()
                 .setMethodDescriptor(listPrivateConnectionsMethodDescriptor)
                 .setParamsExtractor(
-                    new RequestParamsExtractor<ListPrivateConnectionsRequest>() {
-                      @Override
-                      public Map<String, String> extract(ListPrivateConnectionsRequest request) {
-                        ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
-                        params.put("parent", String.valueOf(request.getParent()));
-                        return params.build();
-                      }
+                    request -> {
+                      ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                      params.put("parent", String.valueOf(request.getParent()));
+                      return params.build();
                     })
                 .build();
     GrpcCallSettings<DeletePrivateConnectionRequest, Operation>
@@ -634,65 +584,50 @@ public Map<String, String> extract(ListPrivateConnectionsRequest request) {
             GrpcCallSettings.<DeletePrivateConnectionRequest, Operation>newBuilder()
                 .setMethodDescriptor(deletePrivateConnectionMethodDescriptor)
                 .setParamsExtractor(
-                    new RequestParamsExtractor<DeletePrivateConnectionRequest>() {
-                      @Override
-                      public Map<String, String> extract(DeletePrivateConnectionRequest request) {
-                        ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
-                        params.put("name", String.valueOf(request.getName()));
-                        return params.build();
-                      }
+                    request -> {
+                      ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                      params.put("name", String.valueOf(request.getName()));
+                      return params.build();
                     })
                 .build();
     GrpcCallSettings<CreateRouteRequest, Operation> createRouteTransportSettings =
         GrpcCallSettings.<CreateRouteRequest, Operation>newBuilder()
             .setMethodDescriptor(createRouteMethodDescriptor)
             .setParamsExtractor(
-                new RequestParamsExtractor<CreateRouteRequest>() {
-                  @Override
-                  public Map<String, String> extract(CreateRouteRequest request) {
-                    ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
-                    params.put("parent", String.valueOf(request.getParent()));
-                    return params.build();
-                  }
+                request -> {
+                  ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                  params.put("parent", String.valueOf(request.getParent()));
+                  return params.build();
                 })
             .build();
     GrpcCallSettings<GetRouteRequest, Route> getRouteTransportSettings =
         GrpcCallSettings.<GetRouteRequest, Route>newBuilder()
             .setMethodDescriptor(getRouteMethodDescriptor)
             .setParamsExtractor(
-                new RequestParamsExtractor<GetRouteRequest>() {
-                  @Override
-                  public Map<String, String> extract(GetRouteRequest request) {
-                    ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
-                    params.put("name", String.valueOf(request.getName()));
-                    return params.build();
-                  }
+                request -> {
+                  ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                  params.put("name", String.valueOf(request.getName()));
+                  return params.build();
                 })
             .build();
     GrpcCallSettings<ListRoutesRequest, ListRoutesResponse> listRoutesTransportSettings =
         GrpcCallSettings.<ListRoutesRequest, ListRoutesResponse>newBuilder()
             .setMethodDescriptor(listRoutesMethodDescriptor)
             .setParamsExtractor(
-                new RequestParamsExtractor<ListRoutesRequest>() {
-                  @Override
-                  public Map<String, String> extract(ListRoutesRequest request) {
-                    ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
-                    params.put("parent", String.valueOf(request.getParent()));
-                    return params.build();
-                  }
+                request -> {
+                  ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                  params.put("parent", String.valueOf(request.getParent()));
+                  return params.build();
                 })
             .build();
     GrpcCallSettings<DeleteRouteRequest, Operation> deleteRouteTransportSettings =
         GrpcCallSettings.<DeleteRouteRequest, Operation>newBuilder()
             .setMethodDescriptor(deleteRouteMethodDescriptor)
             .setParamsExtractor(
-                new RequestParamsExtractor<DeleteRouteRequest>() {
-                  @Override
-                  public Map<String, String> extract(DeleteRouteRequest request) {
-                    ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
-                    params.put("name", String.valueOf(request.getName()));
-                    return params.build();
-                  }
+                request -> {
+                  ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                  params.put("name", String.valueOf(request.getName()));
+                  return params.build();
                 })
             .build();
 
@@ -1084,7 +1019,13 @@ public UnaryCallable<DeleteRouteRequest, Operation> deleteRouteCallable() {
 
   @Override
   public final void close() {
-    shutdown();
+    try {
+      backgroundResources.close();
+    } catch (RuntimeException e) {
+      throw e;
+    } catch (Exception e) {
+      throw new IllegalStateException("Failed to close resource", e);
+    }
   }
 
   @Override