|
29 | 29 | import com.google.api.gax.rpc.UnaryCallable; |
30 | 30 | import com.google.cloud.logging.v2.stub.LoggingServiceV2Stub; |
31 | 31 | import com.google.cloud.logging.v2.stub.LoggingServiceV2StubSettings; |
| 32 | +import com.google.common.util.concurrent.MoreExecutors; |
32 | 33 | import com.google.logging.v2.DeleteLogRequest; |
33 | 34 | import com.google.logging.v2.ListLogEntriesRequest; |
34 | 35 | import com.google.logging.v2.ListLogEntriesResponse; |
@@ -866,7 +867,8 @@ public static ApiFuture<ListLogEntriesPagedResponse> createAsync( |
866 | 867 | public ListLogEntriesPagedResponse apply(ListLogEntriesPage input) { |
867 | 868 | return new ListLogEntriesPagedResponse(input); |
868 | 869 | } |
869 | | - }); |
| 870 | + }, |
| 871 | + MoreExecutors.directExecutor()); |
870 | 872 | } |
871 | 873 |
|
872 | 874 | private ListLogEntriesPagedResponse(ListLogEntriesPage page) { |
@@ -954,7 +956,8 @@ public ListMonitoredResourceDescriptorsPagedResponse apply( |
954 | 956 | ListMonitoredResourceDescriptorsPage input) { |
955 | 957 | return new ListMonitoredResourceDescriptorsPagedResponse(input); |
956 | 958 | } |
957 | | - }); |
| 959 | + }, |
| 960 | + MoreExecutors.directExecutor()); |
958 | 961 | } |
959 | 962 |
|
960 | 963 | private ListMonitoredResourceDescriptorsPagedResponse( |
@@ -1047,7 +1050,8 @@ public static ApiFuture<ListLogsPagedResponse> createAsync( |
1047 | 1050 | public ListLogsPagedResponse apply(ListLogsPage input) { |
1048 | 1051 | return new ListLogsPagedResponse(input); |
1049 | 1052 | } |
1050 | | - }); |
| 1053 | + }, |
| 1054 | + MoreExecutors.directExecutor()); |
1051 | 1055 | } |
1052 | 1056 |
|
1053 | 1057 | private ListLogsPagedResponse(ListLogsPage page) { |
|
0 commit comments