| /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 | 24 val future = GlobalScope.future { in <lambda>() constant
34 val future = SettableFuture.create<Int>() in <lambda>() constant
47 val future = SettableFuture.create<Int>() in <lambda>() constant
63 val future = GlobalScope.future { in <lambda>() constant
72 val future = GlobalScope.future { in <lambda>() constant
84 val future = GlobalScope.future { in <lambda>() constant
98 val future = GlobalScope.future { in <lambda>() constant
114 val future = GlobalScope.future { in <lambda>() constant
148 val future = deferred.asListenableFuture() in <lambda>() constant
161 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
|
| /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 | 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 | 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 | 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
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()
|
| /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 | 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 | 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 | 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
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()
|
| /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/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/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/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
|