| /external/rust/crates/futures/tests/ |
| D | macro_comma_support.rs | 29 let future1 = async { 1 }; in join() localVariable
38 let future1 = async { 1 }.never_error(); in try_join() localVariable
|
| D | try_join.rs | 20 let future1 = async { Ok::<(), Never>(()) }; in try_join_never_error() localVariable
30 let future1 = async { Err::<Never, ()>(()) }; in try_join_never_ok() localVariable
|
| D | future_shared.rs | 88 let future1 = future::lazy(move |_| { in drop_in_poll() localVariable
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | ClosingFuture.java | 474 ClosingFuture<?> future1, ClosingFuture<?>... moreFutures) { in whenAllComplete()
500 Combiner2<V1, V2> whenAllSucceed(ClosingFuture<V1> future1, ClosingFuture<V2> future2) { in whenAllSucceed()
517 ClosingFuture<V1> future1, ClosingFuture<V2> future2, ClosingFuture<V3> future3) { in whenAllSucceed()
537 ClosingFuture<V1> future1, in whenAllSucceed()
561 ClosingFuture<V1> future1, in whenAllSucceed()
577 ClosingFuture<?> future1, in whenAllSucceed()
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | ClosingFuture.java | 472 ClosingFuture<?> future1, ClosingFuture<?>... moreFutures) { in whenAllComplete()
498 Combiner2<V1, V2> whenAllSucceed(ClosingFuture<V1> future1, ClosingFuture<V2> future2) { in whenAllSucceed()
515 ClosingFuture<V1> future1, ClosingFuture<V2> future2, ClosingFuture<V3> future3) { in whenAllSucceed()
535 ClosingFuture<V1> future1, in whenAllSucceed()
559 ClosingFuture<V1> future1, in whenAllSucceed()
575 ClosingFuture<?> future1, in whenAllSucceed()
|
| /external/connectedappssdk/tests/robotests/src/test/java/com/google/android/enterprise/connectedapps/internal/ |
| D | CrossProfileCallbackMultiMergerTest.java | 214 ListenableFuture<String> future1 = Futures.submit(() -> "Hello", executorWithThread1); in listenableFuturesCompletingOnSeparateThreads() local
240 ListenableFuture<String> future1 = Futures.submit(() -> "Hello", executorWithThread1); in listenableFuturesCompletingWithErrorsOnSeparateThreads() local
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | ExecutionSequencerTest.java | 120 ListenableFuture<Void> future1 = serializer.submit(blockingCallable, executor); in testSecondTaskWaitsForFirstEvenIfCancelled() local
|
| /external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| D | ExecutionSequencerTest.java | 120 ListenableFuture<Void> future1 = serializer.submit(blockingCallable, executor); in testSecondTaskWaitsForFirstEvenIfCancelled() local
|
| /external/rust/crates/tokio/tests/ |
| D | sync_notify.rs | 204 let mut future1 = spawn(notify.notified()); in test_enable_consumes_permit() localVariable
|
| /external/conscrypt/repackaged/common/src/test/java/com/android/org/conscrypt/javax/net/ssl/ |
| D | SSLSocketVersionCompatibilityTest.java | 232 final Future<byte[]> future1 = runAsync(new SSLServerSessionIdCallable(server1)); in test_SSLSocket_confirmSessionReuse() local
|
| /external/conscrypt/common/src/test/java/org/conscrypt/javax/net/ssl/ |
| D | SSLSocketVersionCompatibilityTest.java | 230 final Future<byte[]> future1 = runAsync(new SSLServerSessionIdCallable(server1)); in test_SSLSocket_confirmSessionReuse() local
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ManagedChannelImplTest.java | 2769 ListenableFuture<Void> future1 = ClientCalls.futureUnaryCall(call1, null); in badServiceConfigIsRecoverable() local
|