Searched refs:futureResult (Results 1 – 10 of 10) sorted by relevance
41 final CompletableFuture<AppSearchResult<T>> futureResult = new CompletableFuture<>(); in executeAppSearchResultOperation() local45 operation.accept(futureResult::complete); in executeAppSearchResultOperation()50 AppSearchResult<T> result = futureResult.get(); in executeAppSearchResultOperation()71 final CompletableFuture<AppSearchBatchResult<T, V>> futureResult = in executeAppSearchBatchResultOperation() local81 futureResult.complete(value); in executeAppSearchBatchResultOperation()86 futureResult.completeExceptionally(throwable); in executeAppSearchBatchResultOperation()92 return futureResult.get(); in executeAppSearchBatchResultOperation()
100 final List<WorkInfo> futureResult = List.of( in testUniqueWorkStatusForPendingWork() local104 future.set(futureResult); in testUniqueWorkStatusForPendingWork()114 final List<WorkInfo> futureResult = List.of( in testUniqueWorkStatusForCompletedWork() local119 future.set(futureResult); in testUniqueWorkStatusForCompletedWork()
299 final SettableFuture<Optional<Uri>> futureResult = SettableFuture.create(); in saveAndFinish() local313 futureResult.set(Optional.fromNullable(uri)); in saveAndFinish()325 futureResult.set(Optional.fromNullable(mUri)); in saveAndFinish()336 futureResult.setException(e); in saveAndFinish()339 return futureResult; in saveAndFinish()
396 ListenableFuture<T> futureResult = function.get(); in waitForFuture() local397 futureResult.addListener(resultLatch::countDown, mLightweightExecutorService); in waitForFuture()399 return futureResult.get(); in waitForFuture()
472 ListenableFuture<T> futureResult = function.get(); in waitForFuture() local473 futureResult.addListener(resultLatch::countDown, mLightweightExecutorService); in waitForFuture()475 return futureResult.get(); in waitForFuture()
1315 AtomicReference<ListenableFuture<T>> futureResult = new AtomicReference<>();1316 futureResult.set(function.get());1317 futureResult.get().addListener(resultLatch::countDown, mExecutorService);1319 return futureResult.get().get();
1877 AtomicReference<ListenableFuture<T>> futureResult = new AtomicReference<>();1878 futureResult.set(function.get());1879 futureResult.get().addListener(resultLatch::countDown, EXECUTOR_SERVICE);1881 return futureResult.get().get();
1998 ListenableFuture<T> futureResult = function.get(); in waitForFuture() local1999 futureResult.addListener(resultLatch::countDown, mLightweightExecutorService); in waitForFuture()2001 return futureResult.get(); in waitForFuture()
3250 ListenableFuture<T> futureResult = function.get(); in waitForFuture() local3251 futureResult.addListener(resultLatch::countDown, mLightweightExecutorService); in waitForFuture()3253 return futureResult.get(); in waitForFuture()
1176 ListenableFuture<String> futureResult = in callJSEngine() local1186 return futureResult.get(); in callJSEngine()1199 ListenableFuture<String> futureResult = in callJSEngine() local1210 return futureResult.get(); in callJSEngine()