|
29 | 29 | import com.google.api.gax.rpc.UnaryCallable; |
30 | 30 | import com.google.cloud.monitoring.v3.stub.MetricServiceStub; |
31 | 31 | import com.google.cloud.monitoring.v3.stub.MetricServiceStubSettings; |
| 32 | +import com.google.common.util.concurrent.MoreExecutors; |
32 | 33 | import com.google.monitoring.v3.CreateMetricDescriptorRequest; |
33 | 34 | import com.google.monitoring.v3.CreateTimeSeriesRequest; |
34 | 35 | import com.google.monitoring.v3.DeleteMetricDescriptorRequest; |
@@ -1239,7 +1240,8 @@ public ListMonitoredResourceDescriptorsPagedResponse apply( |
1239 | 1240 | ListMonitoredResourceDescriptorsPage input) { |
1240 | 1241 | return new ListMonitoredResourceDescriptorsPagedResponse(input); |
1241 | 1242 | } |
1242 | | - }); |
| 1243 | + }, |
| 1244 | + MoreExecutors.directExecutor()); |
1243 | 1245 | } |
1244 | 1246 |
|
1245 | 1247 | private ListMonitoredResourceDescriptorsPagedResponse( |
@@ -1337,7 +1339,8 @@ public static ApiFuture<ListMetricDescriptorsPagedResponse> createAsync( |
1337 | 1339 | public ListMetricDescriptorsPagedResponse apply(ListMetricDescriptorsPage input) { |
1338 | 1340 | return new ListMetricDescriptorsPagedResponse(input); |
1339 | 1341 | } |
1340 | | - }); |
| 1342 | + }, |
| 1343 | + MoreExecutors.directExecutor()); |
1341 | 1344 | } |
1342 | 1345 |
|
1343 | 1346 | private ListMetricDescriptorsPagedResponse(ListMetricDescriptorsPage page) { |
@@ -1424,7 +1427,8 @@ public static ApiFuture<ListTimeSeriesPagedResponse> createAsync( |
1424 | 1427 | public ListTimeSeriesPagedResponse apply(ListTimeSeriesPage input) { |
1425 | 1428 | return new ListTimeSeriesPagedResponse(input); |
1426 | 1429 | } |
1427 | | - }); |
| 1430 | + }, |
| 1431 | + MoreExecutors.directExecutor()); |
1428 | 1432 | } |
1429 | 1433 |
|
1430 | 1434 | private ListTimeSeriesPagedResponse(ListTimeSeriesPage page) { |
|
0 commit comments