| /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/modules/Gki/ |
| D | download_boot_prebuilt.py | 34 from concurrent import futures
108 with futures.ThreadPoolExecutor(max_workers=10) as pool:
121 futures.wait([f for ver, arch, f in fs])
|
| /packages/modules/GeoTZ/data_pipeline/src/main/java/com/android/timezone/location/data_pipeline/steps/ |
| D | TzS2PolygonsToTzS2CellUnions.java | 141 List<NamedFuture<Pair<String, File>>> futures = new ArrayList<>(); in execute() local
146 futures.add(namedFuture); in execute()
150 for (NamedFuture<Pair<String, File>> future : futures) { in execute()
|
| D | TzS2CellUnionsToTzS2Ranges.java | 139 List<NamedFuture<Pair<String, File>>> futures = new ArrayList<>(); in execute() local
144 futures.add(namedFuture); in execute()
148 for (NamedFuture<Pair<String, File>> future : futures) { in execute()
|
| D | GeoJsonTzToTzS2Polygons.java | 165 List<NamedFuture<TzS2Polygons>> futures = new ArrayList<>(features.size()); in execute() local
174 futures.add(namedFuture); in execute()
178 for (NamedFuture<TzS2Polygons> future : futures) { in execute()
|
| /packages/services/Telephony/testapps/TestRcsApp/aosp_test_rcsclient/src/com/android/libraries/rcs/simpleclient/protocol/msrp/ |
| D | MsrpSession.java | 36 import androidx.concurrent.futures.CallbackToFutureAdapter;
37 import androidx.concurrent.futures.CallbackToFutureAdapter.Completer;
|
| /packages/services/Telephony/testapps/TestRcsApp/aosp_test_rcsclient/ |
| D | Android.bp | 29 "androidx.concurrent_concurrent-futures",
|
| /packages/modules/DnsResolver/tests/ |
| D | resolv_tls_unit_test.cpp | 979 std::vector<std::unique_ptr<DnsTlsQueryMap::QueryFuture>> futures(UINT16_MAX + 1); in TEST() local
981 futures[i] = map.recordQuery(makeSlice(QUERY)); in TEST()
982 ASSERT_TRUE(futures[i]); // answers[i] should be nonnull. in TEST()
983 EXPECT_EQ(i, futures[i]->query.newId); in TEST()
995 auto result = futures[40000]->result.get(); in TEST()
|
| /packages/modules/NetworkStack/src/com/android/server/connectivity/ |
| D | NetworkMonitor.java | 2847 final List<Future<CaptivePortalProbeResult>> futures = new ArrayList<>(); in sendMultiParallelHttpAndHttpsProbes() local
2859 futures.add(ecs.submit(() -> new HttpProbe(properties, proxy, url, in sendMultiParallelHttpAndHttpsProbes()
2864 futures.add(ecs.submit(() -> new HttpsProbe(properties, proxy, url, capportApiUrl) in sendMultiParallelHttpAndHttpsProbes()
2885 futures.forEach(future -> future.cancel(true)); in sendMultiParallelHttpAndHttpsProbes()
|
| /packages/inputmethods/LatinIME/dictionaries/ |
| D | en_GB_wordlist.combined.gz | 1dictionary=main:en_gb,locale=en_GB,description=English (UK),date ... |
| D | en_US_wordlist.combined.gz | |
| D | nl_wordlist.combined.gz | 1dictionary=main:nl,locale=nl,description=Nederlands,date=1414726258, ... |
| D | pt_BR_wordlist.combined.gz | 1dictionary=main:pt_br,locale=pt_BR,description=Português (Brasil),date ... |
| D | en_wordlist.combined.gz | 1dictionary=main:en,locale=en,description=English,date=1414726273, ... |
| D | da_wordlist.combined.gz | 1dictionary=main:da,locale=da,description=Dansk,date=1393228134, ... |
| D | pl_wordlist.combined.gz | 1dictionary=main:pl,locale=pl,description=Polski,date=1414726264, ... |
| D | hr_wordlist.combined.gz | |
| D | pt_PT_wordlist.combined.gz | 1dictionary=main:pt_pt,locale=pt_PT,description=Português (Portugal),date ... |
| D | fr_wordlist.combined.gz | 1dictionary=main:fr,locale=fr,description=Français,date=1414726264, ... |