Home
last modified time | relevance | path

Searched refs:thenCompose (Results 1 – 14 of 14) sorted by relevance

/packages/modules/AppSearch/service/java/com/android/server/appsearch/contactsindexer/
DContactsIndexerImpl.java133 .thenCompose( in updatePersonCorpusAsync()
166 batchRemoveFuture.thenCompose( in batchRemoveContactsAsync()
230 return future.thenCompose( in batchUpdateContactsAsync()
244 future.thenCompose( in batchUpdateContactsAsync()
266 return future.thenCompose(x -> CompletableFuture.failedFuture(e)); in batchUpdateContactsAsync()
374 .thenCompose(x -> CompletableFuture.failedFuture(e)); in indexContactsFromCursorAsync()
461 .thenCompose( in add()
465 .thenCompose( in add()
483 .thenCompose( in flushAsync()
487 .thenCompose(y -> flushPendingIndexAsync(updateStats)); in flushAsync()
[all …]
DAppSearchHelper.java131 createSessionFuture.thenCompose( in initializeAsync()
152 .thenCompose( in initializeAsync()
320 return mAppSearchSessionFuture.thenCompose( in indexContactsAsync()
424 return mAppSearchSessionFuture.thenCompose( in removeContactsByIdAsync()
511 return mAppSearchSessionFuture.thenCompose(
555 return mAppSearchSessionFuture.thenCompose(
570 .thenCompose(
601 .thenCompose(
643 return future.thenCompose(
DContactsIndexerUserInstance.java188 .thenCompose( in startAsync()
349 .thenCompose( in doFullUpdateInternalAsync()
/packages/services/Car/tests/carservice_unit_test/src/android/car/util/concurrent/
DAndroidFutureTest.java282 AndroidFuture<String> composedFuture = mUncompletedFuture.thenCompose( in testThenCompose()
298 AndroidFuture<String> composedFuture = mUncompletedFuture.thenCompose(s -> throwingFuture); in testThenCompose_functionThrowingException()
/packages/services/Car/car-usb-handler/src/android/car/usb/handler/
DAoapServiceManager.java275 return mConnected.thenCompose(x -> { in sendMessageForResult()
/packages/modules/AppSearch/testing/contactsindexertests/src/com/android/server/appsearch/contactsindexer/
DAppSearchHelperTest.java327 .thenCompose(x -> mAppSearchHelper.indexContactsAsync(batchedContacts, in indexContactsInBatchesAsync()
DContactsIndexerUserInstanceTest.java999 CompletableFuture<T> chainedFuture = future.get().thenCompose(x -> stage); in executeAndWaitForCompletion()
/packages/services/Car/car-lib/src/android/car/util/concurrent/
DAndroidFuture.java299 public <U> AndroidFuture<U> thenCompose( in thenCompose() method in AndroidFuture
/packages/services/Telephony/src/com/android/services/telephony/rcs/
DSipTransportController.java804 CompletableFuture<Set<String>> pendingChange = pendingDestroy.thenCompose((ignore) -> { in reevaluateDelegates()
/packages/services/Car/tests/carservice_unit_test/res/raw/
Dcar_hidden_apis_release_33.2.txt715 android.car.util.concurrent AndroidFuture AndroidFuture<U> thenCompose(Function<? super T,? extends…
Dcar_hidden_apis_release_33.1.txt706 android.car.util.concurrent AndroidFuture AndroidFuture<U> thenCompose(Function<? super T,? extends…
Dcar_hidden_apis.txt772 android.car.util.concurrent AndroidFuture AndroidFuture<U> thenCompose(Function<? super T,? extends…
Dcar_hidden_apis_release_33.3.txt801 android.car.util.concurrent AndroidFuture AndroidFuture<U> thenCompose(Function<? super T,? extends…
/packages/services/Car/tools/GenericCarApiBuilder/
Dcomplete_car_api_list.txt2199 …method TIRAMISU_0 AndroidFuture<U> thenCompose(Function<? super T,? extends CompletionStage<U>> fn…