| /packages/apps/Dialer/java/com/android/dialer/common/concurrent/ |
| D | DialerFutures.java | 45 Iterable<? extends ListenableFuture<? extends T>> futures, in firstMatching() argument
48 return firstMatchingImpl(futures, predicate, defaultValue); in firstMatching()
52 Iterable<? extends ListenableFuture<? extends T>> futures, in firstMatchingImpl() argument
55 AggregateFuture<T> output = new AnyOfFuture<>(futures); in firstMatchingImpl()
57 final AtomicInteger pending = new AtomicInteger(output.futures.size()); in firstMatchingImpl()
58 for (final ListenableFuture<? extends T> future : output.futures) { in firstMatchingImpl()
94 ImmutableList<ListenableFuture<? extends T>> futures; field in DialerFutures.AggregateFuture
96 AggregateFuture(Iterable<? extends ListenableFuture<? extends T>> futures) { in AggregateFuture() argument
97 ImmutableList<ListenableFuture<? extends T>> futuresCopy = ImmutableList.copyOf(futures); in AggregateFuture()
101 this.futures = futuresCopy; in AggregateFuture()
[all …]
|
| /packages/apps/Dialer/java/com/android/dialer/phonelookup/composite/ |
| D | CompositePhoneLookup.java | 88 List<ListenableFuture<?>> futures = new ArrayList<>(); in lookup() local
94 futures.add(lookupFuture); in lookup()
96 ListenableFuture<PhoneLookupInfo> combinedFuture = combineSubMessageFutures(futures); in lookup()
112 List<ListenableFuture<?>> futures = new ArrayList<>(); in lookup() local
118 futures.add(lookupFuture); in lookup()
120 ListenableFuture<PhoneLookupInfo> combinedFuture = combineSubMessageFutures(futures); in lookup()
149 List<ListenableFuture<Boolean>> futures = new ArrayList<>(); in isDirty() local
152 futures.add(isDirtyFuture); in isDirty()
159 DialerFutures.firstMatching(futures, Preconditions::checkNotNull, false /* defaultValue */); in isDirty()
178 List<ListenableFuture<ImmutableMap<DialerPhoneNumber, ?>>> futures = new ArrayList<>(); in getMostRecentInfo()
[all …]
|
| /packages/apps/Camera2/src/com/android/camera/async/ |
| D | Futures2.java | 91 ListenableFuture<?>[] futures = new ListenableFuture<?>[2];
93 futures[0] = f1;
94 futures[1] = f2;
99 ListenableFuture<List<Object>> result = Futures.<Object>allAsList(futures);
135 ListenableFuture<?>[] futures = new ListenableFuture<?>[3];
137 futures[0] = f1;
138 futures[1] = f2;
139 futures[2] = f3;
144 ListenableFuture<List<Object>> result = Futures.<Object>allAsList(futures);
|
| /packages/providers/MediaProvider/tests/src/com/android/providers/media/photopicker/sync/ |
| D | SyncTrackerTests.java | 38 Collection<CompletableFuture<Object>> futures = syncTracker.pendingSyncFutures(); in testCreateSyncFuture() local
39 assertThat(futures.size()).isEqualTo(1); in testCreateSyncFuture()
48 Collection<CompletableFuture<Object>> futures = syncTracker.pendingSyncFutures(); in testMarkSyncAsComplete() local
49 assertThat(futures.size()).isEqualTo(0); in testMarkSyncAsComplete()
|
| /packages/modules/Permission/tests/cts/permissionui/src/android/permissionui/cts/ |
| D | StartForFutureActivity.kt | 42 futures.put(requestCode, future) in startActivityForFuture()
49 futures.remove(requestCode) in onActivityResult()
60 private val futures = LruCache<Int, CompletableFuture<Instrumentation.ActivityResult>>(10) constant
|
| /packages/modules/DeviceLock/DeviceLockController/src/com/android/devicelockcontroller/policy/ |
| D | DevicePolicyControllerImpl.java | 264 List<ListenableFuture<Boolean>> futures = new ArrayList<>();
269 futures.add(policy.onCleared());
278 futures.add(policy.onUnlocked());
281 futures.add(policy.onLocked());
296 futures.add(policy.onProvisionInProgress());
299 futures.add(policy.onProvisioned());
302 futures.add(policy.onProvisionPaused());
305 futures.add(policy.onProvisionFailed());
313 return Futures.transform(Futures.allAsList(futures),
|
| /packages/modules/Bluetooth/system/blueberry/tests/gd/cert/ |
| D | async_subprocess_logger.py | 17 import concurrent.futures
61 self.executor = concurrent.futures.ThreadPoolExecutor(max_workers=1)
72 except concurrent.futures.TimeoutError:
|
| /packages/modules/Bluetooth/system/blueberry/grpc/ |
| D | blueberry_device_controller.py | 7 from concurrent import futures
27 futures.ThreadPoolExecutor(max_workers=FLAGS.threads),
|
| /packages/modules/HealthFitness/testapps/toolbox/src/com/android/healthconnect/testapps/toolbox/utils/ |
| D | SuspendToFutureAdapter.kt | 18 import androidx.concurrent.futures.CallbackToFutureAdapter in <lambda>()
19 import androidx.concurrent.futures.DirectExecutor in <lambda>()
|
| /packages/modules/Bluetooth/system/gd/rust/topshim/facade/src/ |
| D | main.rs | 6 use futures::channel::mpsc;
7 use futures::executor::block_on;
8 use futures::stream::StreamExt;
|
| /packages/modules/Uwb/generic_ranging/ |
| D | Android.bp | 37 "androidx.concurrent_concurrent-futures",
38 "androidx.concurrent_concurrent-futures",
|
| /packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/adselection/ |
| D | DebugReportSenderStrategyHttpImpl.java | 71 List<ListenableFuture<Void>> futures = in flush() local
79 return Futures.whenAllComplete(futures).call(() -> null, in flush()
|
| /packages/modules/Uwb/androidx_backend/src/androidx/core/uwb/backend/impl/internal/ |
| D | OpAsyncCallbackRunner.java | 27 import androidx.concurrent.futures.CallbackToFutureAdapter;
28 import androidx.concurrent.futures.CallbackToFutureAdapter.Completer;
|
| /packages/modules/GeoTZ/data_pipeline/src/main/java/com/android/timezone/location/data_pipeline/steps/ |
| D | TzS2PolygonsToTzS2CellUnions.java | 140 List<NamedFuture<Pair<String, File>>> futures = new ArrayList<>(); in execute() local
145 futures.add(namedFuture); in execute()
149 for (NamedFuture<Pair<String, File>> future : futures) { in execute()
|
| D | TzS2CellUnionsToTzS2Ranges.java | 138 List<NamedFuture<Pair<String, File>>> futures = new ArrayList<>(); in execute() local
143 futures.add(namedFuture); in execute()
147 for (NamedFuture<Pair<String, File>> future : futures) { in execute()
|
| /packages/modules/AdServices/adservices/tests/cts/endtoends/topics/connection/ |
| D | Android.bp | 26 "androidx.concurrent_concurrent-futures",
57 "androidx.concurrent_concurrent-futures",
|
| /packages/modules/AdServices/adservices/tests/cts/endtoends/topics/mdd/ |
| D | Android.bp | 26 "androidx.concurrent_concurrent-futures",
57 "androidx.concurrent_concurrent-futures",
|
| /packages/modules/AdServices/adservices/tests/cts/appsetid/ |
| D | Android.bp | 28 "androidx.concurrent_concurrent-futures",
62 "androidx.concurrent_concurrent-futures",
|
| /packages/modules/AdServices/adservices/tests/cts/endtoends/permissions/noperm/ |
| D | Android.bp | 29 "androidx.concurrent_concurrent-futures",
62 "androidx.concurrent_concurrent-futures",
|
| /packages/modules/AdServices/adservices/tests/cts/adid/ |
| D | Android.bp | 28 "androidx.concurrent_concurrent-futures",
60 "androidx.concurrent_concurrent-futures",
|
| /packages/modules/AdServices/adservices/tests/cts/endtoends/permissions/notallowed/ |
| D | Android.bp | 29 "androidx.concurrent_concurrent-futures",
62 "androidx.concurrent_concurrent-futures",
|
| /packages/modules/AdServices/adservices/tests/cts/extdata/ |
| D | Android.bp | 28 "androidx.concurrent_concurrent-futures",
60 "androidx.concurrent_concurrent-futures",
|
| /packages/modules/AdServices/adservices/tests/cts/endtoends/permissions/valid/ |
| D | Android.bp | 33 "androidx.concurrent_concurrent-futures",
70 "androidx.concurrent_concurrent-futures",
|
| /packages/modules/AdServices/adservices/tests/cts/endtoends/permissions/appoptout/ |
| D | Android.bp | 33 "androidx.concurrent_concurrent-futures",
70 "androidx.concurrent_concurrent-futures",
|
| /packages/modules/AdServices/adservices/tests/endtoends/ |
| D | Android.bp | 27 "androidx.concurrent_concurrent-futures",
58 "androidx.concurrent_concurrent-futures",
|