| /work/work-runtime/src/test/java/androidx/work/ |
| D | ListenableFutureTest.kt | 33 val future = in testFailure() constant
48 val future = executor.executeAsync("testSuccess") { "hello" } in testSuccess() constant
56 val future = executor.executeAsync("testCancellation") { wasCalled = true } in testCancellation() constant
|
| /work/work-runtime/src/androidTest/java/androidx/work/impl/workers/ |
| D | ConstraintTrackingWorkerTest.kt | 99 val future = workerWrapper.launch() in <lambda>() constant
111 val future = workerWrapper.launch() in <lambda>() constant
120 val future = workerWrapper.launch() in <lambda>() constant
131 val future = workerWrapper.launch() in <lambda>() constant
142 val future = workerWrapper.launch() in <lambda>() constant
157 val future = workerWrapper.launch() in <lambda>() constant
|
| /work/work-runtime/src/main/java/androidx/work/ |
| D | Operation.kt | 45 val future = in <lambda>() constant
65 private val future: ListenableFuture<Operation.State.SUCCESS>, constant in androidx.work.OperationImpl
|
| D | Worker.kt | 93 private fun <T> Executor.future(block: () -> T): ListenableFuture<T> = in future() method
|
| /work/work-runtime/src/androidTest/java/androidx/work/impl/ |
| D | WorkerWrapperTestKt.kt | 72 val future = workerWrapper.launch() in <lambda>() constant
85 val future = workerWrapper.launch() in <lambda>() constant
98 val future = workerWrapper.launch() in <lambda>() constant
117 val future = workerWrapper.launch() in <lambda>() constant
142 val future = workerWrapper.launch() in testInterruptionPreStartWork() constant
185 val future = workerWrapper.launch() in stopReason_available_in_synchronous_listener_of_startWork() constant
212 val future = workerWrapper.launch() in <lambda>() constant
|
| D | ControlledWorkerWrapperTest.kt | 60 val future = workerWrapper.launch() in testInterruptionsBefore() constant
84 val future = workerWrapper.launch() in testInterruptionsBetweenGetForegroundInfoAsyncAndStartWork() constant
|
| D | WorkerWrapperTest.java | 553 long future = System.currentTimeMillis() + HOURS.toMillis(1); in testBackedOffOneTimeWork_doesNotRun() local
557 mWorkSpecDao.setLastEnqueueTime(retryWork.getStringId(), future); in testBackedOffOneTimeWork_doesNotRun() local
1433 ListenableFuture<Boolean> future = workerWrapper.launch(); in createAndAddFutureListener() local
1455 FutureListener(ListenableFuture<Boolean> future) { in FutureListener()
|
| /work/work-runtime/src/main/java/androidx/work/impl/utils/futures/ |
| D | AbstractFuture.java | 263 final ListenableFuture<? extends V> future; field in AbstractFuture.SetFuture
265 SetFuture(AbstractFuture<V> owner, ListenableFuture<? extends V> future) { in SetFuture()
736 protected boolean setFuture(ListenableFuture<? extends V> future) { in setFuture()
790 static Object getFutureValue(ListenableFuture<?> future) { in getFutureValue()
839 private static <V> V getUninterruptibly(Future<V> future) throws ExecutionException { in getUninterruptibly()
858 static void complete(AbstractFuture<?> future) { in complete()
1064 abstract boolean casWaiters(AbstractFuture<?> future, Waiter expect, Waiter update); in casWaiters()
1067 abstract boolean casListeners(AbstractFuture<?> future, Listener expect, Listener update); in casListeners()
1070 abstract boolean casValue(AbstractFuture<?> future, Object expect, Object update); in casValue()
1105 boolean casWaiters(AbstractFuture<?> future, Waiter expect, Waiter update) { in casWaiters()
[all …]
|
| D | SettableFuture.java | 60 public boolean setFuture(ListenableFuture<? extends V> future) { in setFuture()
|
| /work/work-multiprocess/src/main/java/androidx/work/multiprocess/ |
| D | RemoteWorkerWrapper.kt | 39 val future = in <lambda>() constant
|
| D | RemoteWorkManagerImpl.java | 213 final ListenableFuture<List<WorkInfo>> future = in queryWorkInfo() local
240 final ListenableFuture<Void> future = progressUpdater.updateProgress( in setProgress() local
272 final ListenableFuture<Void> future = foregroundUpdater.setForegroundAsync( in setForegroundAsync() local
|
| D | ListenableCallback.java | 48 @NonNull ListenableFuture<I> future) { in ListenableCallback()
|
| /work/work-rxjava2/src/test/java/androidx/work/ |
| D | RxWorkerTest.kt | 56 val future = worker.startWork() in cancelForwarding() constant
68 val future = worker.startWork() in failedWork() constant
|
| /work/work-rxjava3/src/test/java/androidx/work/rxjava3/ |
| D | RxWorkerTest.kt | 62 val future = worker.startWork() in cancelForwarding() constant
74 val future = worker.startWork() in failedWork() constant
|
| /work/work-runtime/src/androidTest/java/androidx/work/impl/utils/ |
| D | WorkForegroundUpdaterTest.kt | 119 val future = foregroundUpdater.setForegroundAsync(mContext, request.id, metadata) in setForeground_throwsException() constant
|
| /work/work-runtime/src/main/java/androidx/work/impl/workers/ |
| D | ConstraintTrackingWorker.kt | 127 val future = delegate.startWork() in runWorker() constant
|
| /work/work-runtime/src/main/java/androidx/work/impl/ |
| D | Processor.java | 169 ListenableFuture<Boolean> future = workWrapper.launch(); in startWork() local
|