/external/kotlinx.coroutines/integration/kotlinx-coroutines-jdk8/test/future/ |
D | AsFutureTest.kt | 23 val future = deferred.asCompletableFuture() in <lambda>() constant 31 val future = job.asCompletableFuture() in <lambda>() constant 43 val future = deferred.asCompletableFuture() in <lambda>() constant 51 val future = job.asCompletableFuture() in testWaitForJobAsCompletableFuture() constant 61 val future = deferred.asCompletableFuture() in testAsCompletableFutureThrowable() constant 77 val future = job.asCompletableFuture() in testJobAsCompletableFutureThrowable() constant 92 val future = job.asCompletableFuture() in testJobAsCompletableFutureCancellation() constant 107 val future = job.asCompletableFuture() in testJobCancellation() constant 117 val future = deferred.asCompletableFuture() in testDeferredCancellation() constant
|
D | FutureTest.kt | 28 val future = GlobalScope.future { in <lambda>() constant 40 val future = GlobalScope.future { in <lambda>() constant 51 val future = GlobalScope.future { in <lambda>() constant 60 val future = GlobalScope.future { in <lambda>() constant 72 val future = GlobalScope.future { in <lambda>() constant 84 val future = GlobalScope.future { in <lambda>() constant 100 val future = GlobalScope.future { in <lambda>() constant 115 val future = future(start = CoroutineStart.UNDISPATCHED) { in <lambda>() constant 136 val future = GlobalScope.future { in <lambda>() constant 150 val future = GlobalScope.future { in <lambda>() constant [all …]
|
/external/kotlinx.coroutines/integration/kotlinx-coroutines-guava/test/ |
D | ListenableFutureTest.kt | 26 val future = GlobalScope.future { in testSimpleAwait() constant 36 val future = SettableFuture.create<Int>() in <lambda>() constant 49 val future = SettableFuture.create<Int>() constant 65 val future = GlobalScope.future { in testCompletedFuture() constant 74 val future = GlobalScope.future { in testWaitForFuture() constant 86 val future = GlobalScope.future { in testCompletedFutureExceptionally() constant 100 val future = GlobalScope.future { in testWaitForFutureWithException() constant 116 val future = GlobalScope.future { in testExceptionInsideCoroutine() constant 150 val future = deferred.asListenableFuture() in <lambda>() constant 163 val future = deferred.asListenableFuture() in <lambda>() constant [all …]
|
/external/kotlinx.coroutines/integration/kotlinx-coroutines-jdk8/src/future/ |
D | Future.kt | 34 public fun <T> CoroutineScope.future( in <lambda>() method 41 val future = CompletableFuture<T>() in <lambda>() constant 50 private val future: CompletableFuture<T> constant 73 val future = CompletableFuture<T>() in asCompletableFuture() constant 90 val future = CompletableFuture<Unit>() in asCompletableFuture() constant 115 val future = toCompletableFuture() // retrieve the future in asDeferred() constant 159 val future = toCompletableFuture() // retrieve the future in await() constant
|
/external/dagger2/javatests/dagger/producers/internal/ |
D | ProducersTest.java | 42 ListenableFuture<String> future = Futures.immediateFuture("monkey"); in createFutureProduced_success() local 49 ListenableFuture<String> future = Futures.immediateFailedFuture(new RuntimeException("monkey")); in createFutureProduced_failure() local 59 ListenableFuture<String> future = SettableFuture.create(); in createFutureProduced_cancelPropagatesBackwards() local 67 ListenableFuture<String> future = SettableFuture.create(); in createFutureProduced_cancelDoesNotPropagateForwards() local 87 ListenableFuture<String> future = Futures.immediateFuture("monkey"); in createFutureSingletonSet_success() local 94 ListenableFuture<String> future = Futures.immediateFailedFuture(new RuntimeException("monkey")); in createFutureSingletonSet_failure() local 107 ListenableFuture<Set<String>> future = in allAsSet_success() local 117 ListenableFuture<Set<String>> future = in allAsSet_failure() local
|
/external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
D | AbstractFutureTest.java | 70 AbstractFuture<String> future = in testException() local 91 InterruptibleFuture future = new InterruptibleFuture(); in testCancel_notDoneNoInterrupt() local 107 InterruptibleFuture future = new InterruptibleFuture(); in testCancel_notDoneInterrupt() local 123 AbstractFuture<String> future = in testCancel_done() local 135 AbstractFuture<String> future = in testGetWithTimeoutDoneFuture() local 165 final AbstractFuture<String> future = new AbstractFuture<String>() {}; in testRemoveWaiter_interruption() local 189 final AbstractFuture<String> future = new AbstractFuture<String>() {}; in testRemoveWaiter_polling() local 218 SettableFuture<Object> future = SettableFuture.create(); in testToString_oom() local 380 final AbstractFuture<String> future = new AbstractFuture<String>() {}; in testCompletionFinishesWithDone() local 579 final AbstractFuture<String> future = new AbstractFuture<String>() {}; in testFutureBash() local [all …]
|
D | UninterruptibleFutureTest.java | 190 SettableFuture<String> future = SettableFuture.create(); in runUntimedInterruptsTest() local 198 SettableFuture<String> future = SettableFuture.create(); in runTimedInterruptsTest() local 205 int times, SettableFuture<String> future, FutureTask<Boolean> interruptReporter) in runNInterruptsTest() 223 SettableFuture<String> future = SettableFuture.create(); in testMakeUninterruptible_plainFutureSanityCheck() local 241 SettableFuture<String> future = SettableFuture.create(); in testMakeUninterruptible_timedGetZeroTimeoutAttempted() local 254 SettableFuture<String> future = SettableFuture.create(); in testMakeUninterruptible_timedGetNegativeTimeoutAttempted() local 265 final Future<?> future, final boolean allowInterruption) { in untimedInterruptReporter()
|
D | TestPlatform.java | 38 static void verifyGetOnPendingFuture(Future<?> future) { in verifyGetOnPendingFuture() 49 static void verifyTimedGetOnPendingFuture(Future<?> future) { in verifyTimedGetOnPendingFuture() 71 static <V> V getDoneFromTimeoutOverload(Future<V> future) throws ExecutionException { in getDoneFromTimeoutOverload() 72 checkState(future.isDone(), "Future was expected to be done: %s", future); in getDoneFromTimeoutOverload() local
|
D | FuturesTest.java | 135 ListenableFuture<String> future = immediateFuture(DATA1); in testImmediateFuture() local 152 ListenableFuture<String> future = immediateFailedFuture(exception); in testImmediateFailedFuture() local 172 ListenableFuture<String> future = immediateFailedFuture(exception); in testImmediateFailedFuture_cancellationException() local 192 ListenableFuture<String> future = CallerClass1.makeImmediateCancelledFuture(); in testImmediateCancelledFutureBasic() local 198 ListenableFuture<String> future = CallerClass1.makeImmediateCancelledFuture(); in testImmediateCancelledFutureStack() local
|
D | SettableFutureTest.java | 34 private SettableFuture<String> future; field in SettableFutureTest 86 SettableFuture<Integer> future = SettableFuture.create(); in testCreate() local 92 SettableFuture<Integer> future = SettableFuture.create(); in testSetValue_simpleThreaded() local 105 SettableFuture<Object> future = SettableFuture.create(); in testSetException() local 124 SettableFuture<String> future = SettableFuture.create(); in testSetFuture() local 151 SettableFuture<Foo> future = SettableFuture.create(); in testSetFuture_genericsHierarchy() local
|
D | AbstractFutureCancellationCauseTest.java | 86 Future<?> future = newFutureInstance(); in testCancel_notDoneNoInterrupt() local 100 Future<?> future = newFutureInstance(); in testCancel_notDoneInterrupt() local 146 Future<?> future = newFutureInstance(); in testSetFuture_misbehavingFutureDoesNotThrow() local 166 private Throwable tryInternalFastPathGetFailure(Future<?> future) throws Exception { in tryInternalFastPathGetFailure()
|
/external/guava/guava-tests/test/com/google/common/util/concurrent/ |
D | AbstractFutureTest.java | 70 AbstractFuture<String> future = in testException() local 91 InterruptibleFuture future = new InterruptibleFuture(); in testCancel_notDoneNoInterrupt() local 107 InterruptibleFuture future = new InterruptibleFuture(); in testCancel_notDoneInterrupt() local 123 AbstractFuture<String> future = in testCancel_done() local 135 AbstractFuture<String> future = in testGetWithTimeoutDoneFuture() local 165 final AbstractFuture<String> future = new AbstractFuture<String>() {}; in testRemoveWaiter_interruption() local 189 final AbstractFuture<String> future = new AbstractFuture<String>() {}; in testRemoveWaiter_polling() local 218 SettableFuture<Object> future = SettableFuture.create(); in testToString_oom() local 380 final AbstractFuture<String> future = new AbstractFuture<String>() {}; in testCompletionFinishesWithDone() local 579 final AbstractFuture<String> future = new AbstractFuture<String>() {}; in testFutureBash() local [all …]
|
D | UninterruptibleFutureTest.java | 190 SettableFuture<String> future = SettableFuture.create(); in runUntimedInterruptsTest() local 198 SettableFuture<String> future = SettableFuture.create(); in runTimedInterruptsTest() local 205 int times, SettableFuture<String> future, FutureTask<Boolean> interruptReporter) in runNInterruptsTest() 223 SettableFuture<String> future = SettableFuture.create(); in testMakeUninterruptible_plainFutureSanityCheck() local 241 SettableFuture<String> future = SettableFuture.create(); in testMakeUninterruptible_timedGetZeroTimeoutAttempted() local 254 SettableFuture<String> future = SettableFuture.create(); in testMakeUninterruptible_timedGetNegativeTimeoutAttempted() local 265 final Future<?> future, final boolean allowInterruption) { in untimedInterruptReporter()
|
D | TestPlatform.java | 38 static void verifyGetOnPendingFuture(Future<?> future) { in verifyGetOnPendingFuture() 49 static void verifyTimedGetOnPendingFuture(Future<?> future) { in verifyTimedGetOnPendingFuture() 71 static <V> V getDoneFromTimeoutOverload(Future<V> future) throws ExecutionException { in getDoneFromTimeoutOverload() 72 checkState(future.isDone(), "Future was expected to be done: %s", future); in getDoneFromTimeoutOverload() local
|
D | FuturesTest.java | 135 ListenableFuture<String> future = immediateFuture(DATA1); in testImmediateFuture() local 152 ListenableFuture<String> future = immediateFailedFuture(exception); in testImmediateFailedFuture() local 172 ListenableFuture<String> future = immediateFailedFuture(exception); in testImmediateFailedFuture_cancellationException() local 192 ListenableFuture<String> future = CallerClass1.makeImmediateCancelledFuture(); in testImmediateCancelledFutureBasic() local 198 ListenableFuture<String> future = CallerClass1.makeImmediateCancelledFuture(); in testImmediateCancelledFutureStack() local
|
D | SettableFutureTest.java | 34 private SettableFuture<String> future; field in SettableFutureTest 86 SettableFuture<Integer> future = SettableFuture.create(); in testCreate() local 92 SettableFuture<Integer> future = SettableFuture.create(); in testSetValue_simpleThreaded() local 105 SettableFuture<Object> future = SettableFuture.create(); in testSetException() local 124 SettableFuture<String> future = SettableFuture.create(); in testSetFuture() local 151 SettableFuture<Foo> future = SettableFuture.create(); in testSetFuture_genericsHierarchy() local
|
/external/connectedappssdk/tests/robotests/src/test/java/com/google/android/enterprise/connectedapps/robotests/ |
D | BothProfilesListenableFutureTest.java | 108 ListenableFuture<Map<Profile, Void>> future = in both_listenableFuture_blockingMethod_blocks() local 120 ListenableFuture<Map<Profile, Void>> future = in both_listenableFuture_nonblockingMethod_doesNotBlock() local 132 ListenableFuture<Map<Profile, Void>> future = in both_listenableFuture_nonblockingMethod_doesCallback() local 184 ListenableFuture<Map<Profile, Void>> future = in both_listenableFuture_isBound_becomesUnbound_callbackFires() local 197 ListenableFuture<Map<Profile, Void>> future = in both_listenableFuture_profilesWithExceptionsAreNotIncludedInResults() local 209 ListenableFuture<Map<Profile, String>> future = in both_listenableFuture_connectionDropsDuringCall_resultContainsOnlyCurrentProfilesResult() local 227 ListenableFuture<Map<Profile, String>> future = in both_listenableFuture_timeoutSet_doesTimeout() local 243 ListenableFuture<Map<Profile, String>> future = in both_listenableFuture_timeoutSetByCaller_doesTimeout() local
|
D | BothProfilesManualListenableFutureTest.java | 110 ListenableFuture<Map<Profile, Void>> future = in both_listenableFuture_manualConnection_isBound_blockingMethod_blocks() local 123 ListenableFuture<Map<Profile, Void>> future = in both_listenableFuture_manualConnection_isBound_nonblockingMethod_doesNotBlock() local 136 ListenableFuture<Map<Profile, Void>> future = in both_listenableFuture_manualConnection_isBound_nonblockingMethod_doesCallback() local 193 ListenableFuture<Map<Profile, Void>> future = in both_listenableFuture_manualConnection_isBound_becomesUnbound_callbackFires() local 207 ListenableFuture<Map<Profile, Void>> future = in both_listenableFuture_manualConnection_profilesWithExceptionsAreNotIncludedInResults() local 220 ListenableFuture<Map<Profile, String>> future = in both_listenableFuture_manualConnection_connectionDropsDuringCall_resultContainsOnlyCurrentProfilesResult() local
|
D | OtherProfileManualListenableFutureTest.java | 110 ListenableFuture<Void> future = in other_listenableFuture_manualConnection_isNotBound_returnsThrowUnavailableProfileException() local 146 ListenableFuture<String> future = in other_listenableFuture_manualConnection_passesParametersCorrectly() local 154 ListenableFuture<Void> future = in other_listenableFuture_manualConnection_nonblockingMethod_doesNotBlock() local 164 ListenableFuture<Void> future = in other_listenableFuture_manualConnection_nonblockingMethod_doesCallback() local 176 ListenableFuture<Void> future = in other_listenableFuture_manualConnection_connectionIsDroppedDuringCall_setUnavailableProfileException() local
|
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
D | NettyClientHandlerTest.java | 261 ChannelFuture future = cancelStream(Status.CANCELLED); in cancelTwiceShouldSucceed() local 274 ChannelFuture future = cancelStream(Status.CANCELLED); in cancelTwiceDifferentReasons() local 283 ChannelFuture future in sendFrameShouldSucceed() local 295 ChannelFuture future in sendForUnknownStreamShouldFail() local 331 ChannelFuture future = enqueue(new CreateStreamCommand(grpcHeaders, streamTransportState)); in receivedGoAwayShouldCancelBufferedStream() local 342 ChannelFuture future = enqueue(new CreateStreamCommand(grpcHeaders, streamTransportState)); in receivedGoAwayShouldRefuseLaterStreamId() local 350 ChannelFuture future = enqueue(new CreateStreamCommand(grpcHeaders, streamTransportState)); in receivedGoAwayShouldNotAffectEarlyStreamId() local 361 ChannelFuture future = enqueue(new CreateStreamCommand(grpcHeaders, streamTransportState)); in receivedResetWithRefuseCode() local 369 ChannelFuture future = enqueue(new CreateStreamCommand(grpcHeaders, streamTransportState)); in receivedResetWithCanceCode() local 392 ChannelFuture future = enqueue(new CreateStreamCommand(grpcHeaders, streamTransportState)); in receivedGoAwayShouldFailUnknownBufferedStreams() local [all …]
|
/external/guava/guava-gwt/test-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/ |
D | TestPlatform.java | 30 static void verifyGetOnPendingFuture(Future<?> future) { in verifyGetOnPendingFuture() 40 static void verifyTimedGetOnPendingFuture(Future<?> future) { in verifyTimedGetOnPendingFuture() 58 static <V> V getDoneFromTimeoutOverload(Future<V> future) throws ExecutionException { in getDoneFromTimeoutOverload() 59 checkState(future.isDone(), "Future was expected to be done: %s", future); in getDoneFromTimeoutOverload() local
|
/external/jimfs/jimfs/src/test/java/com/google/common/jimfs/ |
D | JimfsAsynchronousFileChannelTest.java | 127 Future<Integer> future = channel.write(ByteBuffer.allocate(10), 0); in testAsyncClose_write() local 161 Future<Integer> future = channel.read(ByteBuffer.allocate(10), 0); in testAsyncClose_read() local 190 SettableFuture<Integer> future = SettableFuture.create(); in checkAsyncRead() local 201 SettableFuture<Integer> future = SettableFuture.create(); in checkAsyncWrite() local 211 SettableFuture<FileLock> future = SettableFuture.create(); in checkAsyncLock() local 221 private static <T> CompletionHandler<T, Object> setFuture(final SettableFuture<T> future) { in setFuture()
|
/external/guava/android/guava-testlib/test/com/google/common/util/concurrent/testing/ |
D | TestingExecutorsTest.java | 47 ScheduledFuture<?> future = in testNoOpScheduledExecutor() local 76 Future<Boolean> future = futureList.get(0); in testNoOpScheduledExecutorInvokeAll() local 97 Future<Integer> future = in testSameThreadScheduledExecutor() local 112 Future<?> future = TestingExecutors.sameThreadScheduledExecutor().submit(runnable); in testSameThreadScheduledExecutorWithException() local
|
/external/guava/guava-testlib/test/com/google/common/util/concurrent/testing/ |
D | TestingExecutorsTest.java | 47 ScheduledFuture<?> future = in testNoOpScheduledExecutor() local 76 Future<Boolean> future = futureList.get(0); in testNoOpScheduledExecutorInvokeAll() local 97 Future<Integer> future = in testSameThreadScheduledExecutor() local 112 Future<?> future = TestingExecutors.sameThreadScheduledExecutor().submit(runnable); in testSameThreadScheduledExecutorWithException() local
|
/external/robolectric/robolectric/src/test/java/org/robolectric/shadows/ |
D | ShadowAccountManagerTest.java | 333 AccountManagerFuture<Boolean> future = am.removeAccount(wrongAccount, null, null); in removeAccount_doesNotRemoveAccountOfDifferentName() local 344 …AccountManagerFuture<Boolean> future = am.removeAccount(account, testAccountManagerCallback, null); in removeAccount_does() local 360 AccountManagerFuture<Bundle> future = in removeAccount_withActivity() local 379 AccountManagerFuture<Bundle> future = in removeAccount_withActivity_doesNotRemoveButReturnsIntent() local 614 AccountManagerFuture<Bundle> future = in startAddAccountSession_withNonNullActivity() local 638 AccountManagerFuture<Bundle> future = in startAddAccountSession_withNullActivity() local 660 AccountManagerFuture<Bundle> future = in startAddAccountSession_missingAuthenticator() local 693 AccountManagerFuture<Bundle> future = in finishSession() local 774 AccountManagerFuture<Bundle> future = in addAccount_noAuthenticatorDefined() local 857 AccountManagerFuture<Bundle> future = am.getAuthToken(account, in getAuthToken_withActivity_returnsCorrectToken() local [all …]
|