| /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 | 25 val future = GlobalScope.future { in <lambda>() constant
35 val future = SettableFuture.create<Int>() in <lambda>() constant
48 val future = SettableFuture.create<Int>() in <lambda>() constant
64 val future = GlobalScope.future { in <lambda>() constant
73 val future = GlobalScope.future { in <lambda>() constant
85 val future = GlobalScope.future { in <lambda>() constant
99 val future = GlobalScope.future { in <lambda>() constant
115 val future = GlobalScope.future { in <lambda>() constant
149 val future = deferred.asListenableFuture() in <lambda>() constant
162 val future = deferred.asListenableFuture() in <lambda>() constant
[all …]
|
| /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
|
| D | SetProducerTest.java | 54 ListenableFuture<Set<Integer>> future = producer.get(); in delegateNpe() local
69 ListenableFuture<Set<Integer>> future = producer.get(); in delegateSetNpe() local
86 ListenableFuture<Set<Integer>> future = producer.get(); in delegateElementNpe() local
|
| /external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| D | AbstractFutureTest.java | 68 AbstractFuture<String> future = in testException() local
89 InterruptibleFuture future = new InterruptibleFuture(); in testCancel_notDoneNoInterrupt() local
105 InterruptibleFuture future = new InterruptibleFuture(); in testCancel_notDoneInterrupt() local
121 AbstractFuture<String> future = in testCancel_done() local
133 AbstractFuture<String> future = in testGetWithTimeoutDoneFuture() local
163 final AbstractFuture<String> future = new AbstractFuture<String>() {}; in testRemoveWaiter_interruption() local
187 final AbstractFuture<String> future = new AbstractFuture<String>() {}; in testRemoveWaiter_polling() local
326 final AbstractFuture<String> future = new AbstractFuture<String>() {}; in testCompletionFinishesWithDone() local
525 final AbstractFuture<String> future = new AbstractFuture<String>() {}; in testFutureBash() local
648 final AbstractFuture<String> future = new AbstractFuture<String>() {}; in testSetFutureCancelBash() local
[all …]
|
| 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 | 136 ListenableFuture<String> future = immediateFuture(DATA1); in testImmediateFuture() local
145 ListenableFuture<String> future = immediateFailedFuture(exception); in testImmediateFailedFuture() local
165 ListenableFuture<String> future = immediateFailedFuture(exception); in testImmediateFailedFuture_cancellationException() local
185 ListenableFuture<String> future = CallerClass1.makeImmediateCancelledFuture(); in testImmediateCancelledFutureBasic() local
191 ListenableFuture<String> future = CallerClass1.makeImmediateCancelledFuture(); in testImmediateCancelledFutureStack() local
|
| D | UninterruptibleFutureTest.java | 183 SettableFuture<String> future = SettableFuture.create(); in runUntimedInterruptsTest() local
191 SettableFuture<String> future = SettableFuture.create(); in runTimedInterruptsTest() local
198 int times, SettableFuture<String> future, FutureTask<Boolean> interruptReporter) in runNInterruptsTest()
216 SettableFuture<String> future = SettableFuture.create(); in testMakeUninterruptible_plainFutureSanityCheck() local
233 SettableFuture<String> future = SettableFuture.create(); in testMakeUninterruptible_timedGetZeroTimeoutAttempted() local
245 SettableFuture<String> future = SettableFuture.create(); in testMakeUninterruptible_timedGetNegativeTimeoutAttempted() local
256 final Future<?> future, final boolean allowInterruption) { in untimedInterruptReporter()
|
| D | SettableFutureTest.java | 34 private SettableFuture<String> future; field in SettableFutureTest
82 SettableFuture<Integer> future = SettableFuture.create(); in testCreate() local
88 SettableFuture<Integer> future = SettableFuture.create(); in testSetValue_simpleThreaded() local
101 SettableFuture<Object> future = SettableFuture.create(); in testSetException() local
120 SettableFuture<String> future = SettableFuture.create(); in testSetFuture() local
147 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()
|
| D | AbstractAbstractFutureTest.java | 44 private TestedFuture<Integer> future; field in AbstractAbstractFutureTest
430 private static void assertSetAsynchronously(AbstractFuture<Integer> future) { in assertSetAsynchronously()
435 private static void assertPending(AbstractFuture<Integer> future) { in assertPending()
447 private static void assertSuccessful(AbstractFuture<Integer> future, Integer expectedResult) in assertSuccessful()
456 private static void assertFailed(AbstractFuture<Integer> future, Throwable expectedException) in assertFailed()
476 private static void assertCancelled(AbstractFuture<Integer> future, boolean expectWasInterrupted) in assertCancelled()
495 private static void assertDone(AbstractFuture<Integer> future) { in assertDone()
505 private static void assertCannotSet(AbstractFuture<Integer> future) { in assertCannotSet()
512 private static void assertCannotCancel(AbstractFuture<Integer> future) { in assertCannotCancel()
|
| D | FuturesGetCheckedTest.java | 61 SettableFuture<String> future = SettableFuture.create(); in testGetCheckedUntimed_interrupted() local
75 SettableFuture<String> future = SettableFuture.create(); in testGetCheckedUntimed_cancelled() local
175 SettableFuture<String> future = SettableFuture.create(); in testGetCheckedTimed_interrupted() local
189 SettableFuture<String> future = SettableFuture.create(); in testGetCheckedTimed_cancelled() local
254 SettableFuture<String> future = SettableFuture.create(); in testGetCheckedTimed_TimeoutException() local
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | AbstractFutureTest.java | 68 AbstractFuture<String> future = in testException() local
89 InterruptibleFuture future = new InterruptibleFuture(); in testCancel_notDoneNoInterrupt() local
105 InterruptibleFuture future = new InterruptibleFuture(); in testCancel_notDoneInterrupt() local
121 AbstractFuture<String> future = in testCancel_done() local
133 AbstractFuture<String> future = in testGetWithTimeoutDoneFuture() local
163 final AbstractFuture<String> future = new AbstractFuture<String>() {}; in testRemoveWaiter_interruption() local
187 final AbstractFuture<String> future = new AbstractFuture<String>() {}; in testRemoveWaiter_polling() local
326 final AbstractFuture<String> future = new AbstractFuture<String>() {}; in testCompletionFinishesWithDone() local
525 final AbstractFuture<String> future = new AbstractFuture<String>() {}; in testFutureBash() local
648 final AbstractFuture<String> future = new AbstractFuture<String>() {}; in testSetFutureCancelBash() local
[all …]
|
| 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 | 136 ListenableFuture<String> future = immediateFuture(DATA1); in testImmediateFuture() local
145 ListenableFuture<String> future = immediateFailedFuture(exception); in testImmediateFailedFuture() local
165 ListenableFuture<String> future = immediateFailedFuture(exception); in testImmediateFailedFuture_cancellationException() local
185 ListenableFuture<String> future = CallerClass1.makeImmediateCancelledFuture(); in testImmediateCancelledFutureBasic() local
191 ListenableFuture<String> future = CallerClass1.makeImmediateCancelledFuture(); in testImmediateCancelledFutureStack() local
|
| D | UninterruptibleFutureTest.java | 183 SettableFuture<String> future = SettableFuture.create(); in runUntimedInterruptsTest() local
191 SettableFuture<String> future = SettableFuture.create(); in runTimedInterruptsTest() local
198 int times, SettableFuture<String> future, FutureTask<Boolean> interruptReporter) in runNInterruptsTest()
216 SettableFuture<String> future = SettableFuture.create(); in testMakeUninterruptible_plainFutureSanityCheck() local
233 SettableFuture<String> future = SettableFuture.create(); in testMakeUninterruptible_timedGetZeroTimeoutAttempted() local
245 SettableFuture<String> future = SettableFuture.create(); in testMakeUninterruptible_timedGetNegativeTimeoutAttempted() local
256 final Future<?> future, final boolean allowInterruption) { in untimedInterruptReporter()
|
| D | SettableFutureTest.java | 34 private SettableFuture<String> future; field in SettableFutureTest
82 SettableFuture<Integer> future = SettableFuture.create(); in testCreate() local
88 SettableFuture<Integer> future = SettableFuture.create(); in testSetValue_simpleThreaded() local
101 SettableFuture<Object> future = SettableFuture.create(); in testSetException() local
120 SettableFuture<String> future = SettableFuture.create(); in testSetFuture() local
147 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()
|
| D | AbstractAbstractFutureTest.java | 44 private TestedFuture<Integer> future; field in AbstractAbstractFutureTest
430 private static void assertSetAsynchronously(AbstractFuture<Integer> future) { in assertSetAsynchronously()
435 private static void assertPending(AbstractFuture<Integer> future) { in assertPending()
447 private static void assertSuccessful(AbstractFuture<Integer> future, Integer expectedResult) in assertSuccessful()
456 private static void assertFailed(AbstractFuture<Integer> future, Throwable expectedException) in assertFailed()
476 private static void assertCancelled(AbstractFuture<Integer> future, boolean expectWasInterrupted) in assertCancelled()
495 private static void assertDone(AbstractFuture<Integer> future) { in assertDone()
505 private static void assertCannotSet(AbstractFuture<Integer> future) { in assertCannotSet()
512 private static void assertCannotCancel(AbstractFuture<Integer> future) { in assertCannotCancel()
|
| /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/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
|
| /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/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 …]
|