|
27 | 27 | import com.google.api.gax.rpc.UnaryCallable; |
28 | 28 | import com.google.cloud.kms.v1.stub.KeyManagementServiceStub; |
29 | 29 | import com.google.cloud.kms.v1.stub.KeyManagementServiceStubSettings; |
| 30 | +import com.google.common.util.concurrent.MoreExecutors; |
30 | 31 | import com.google.iam.v1.GetIamPolicyRequest; |
31 | 32 | import com.google.iam.v1.Policy; |
32 | 33 | import com.google.iam.v1.SetIamPolicyRequest; |
@@ -2852,7 +2853,8 @@ public static ApiFuture<ListKeyRingsPagedResponse> createAsync( |
2852 | 2853 | public ListKeyRingsPagedResponse apply(ListKeyRingsPage input) { |
2853 | 2854 | return new ListKeyRingsPagedResponse(input); |
2854 | 2855 | } |
2855 | | - }); |
| 2856 | + }, |
| 2857 | + MoreExecutors.directExecutor()); |
2856 | 2858 | } |
2857 | 2859 |
|
2858 | 2860 | private ListKeyRingsPagedResponse(ListKeyRingsPage page) { |
@@ -2931,7 +2933,8 @@ public static ApiFuture<ListCryptoKeysPagedResponse> createAsync( |
2931 | 2933 | public ListCryptoKeysPagedResponse apply(ListCryptoKeysPage input) { |
2932 | 2934 | return new ListCryptoKeysPagedResponse(input); |
2933 | 2935 | } |
2934 | | - }); |
| 2936 | + }, |
| 2937 | + MoreExecutors.directExecutor()); |
2935 | 2938 | } |
2936 | 2939 |
|
2937 | 2940 | private ListCryptoKeysPagedResponse(ListCryptoKeysPage page) { |
@@ -3012,7 +3015,8 @@ public static ApiFuture<ListCryptoKeyVersionsPagedResponse> createAsync( |
3012 | 3015 | public ListCryptoKeyVersionsPagedResponse apply(ListCryptoKeyVersionsPage input) { |
3013 | 3016 | return new ListCryptoKeyVersionsPagedResponse(input); |
3014 | 3017 | } |
3015 | | - }); |
| 3018 | + }, |
| 3019 | + MoreExecutors.directExecutor()); |
3016 | 3020 | } |
3017 | 3021 |
|
3018 | 3022 | private ListCryptoKeyVersionsPagedResponse(ListCryptoKeyVersionsPage page) { |
|
0 commit comments