| /external/rust/crates/futures/tests/ |
| D | macro_comma_support.rs | 30 let future2 = async { 2 }; in join() localVariable
39 let future2 = async { 2 }.never_error(); in try_join() localVariable
|
| D | try_join.rs | 21 let future2 = async { Ok::<(), Never>(()) }; in try_join_never_error() localVariable
31 let future2 = async { Err::<Never, ()>(()) }; in try_join_never_ok() localVariable
|
| D | future_shared.rs | 94 let future2 = LocalFutureObj::new(Box::new(future1.clone())); in drop_in_poll() localVariable
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | ClosingFuture.java | 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()
538 ClosingFuture<V2> future2, in whenAllSucceed()
562 ClosingFuture<V2> future2, in whenAllSucceed()
578 ClosingFuture<?> future2, in whenAllSucceed()
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | ClosingFuture.java | 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()
536 ClosingFuture<V2> future2, in whenAllSucceed()
560 ClosingFuture<V2> future2, in whenAllSucceed()
576 ClosingFuture<?> future2, in whenAllSucceed()
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | ExecutionSequencerTest.java | 94 ListenableFuture<Boolean> future2 = in testCancellationMultipleThreads() local
121 ListenableFuture<Boolean> future2 = in testSecondTaskWaitsForFirstEvenIfCancelled() local
|
| D | AbstractFutureTest.java | 233 SettableFuture<Object> future2 = SettableFuture.create(); in testToString_oom() local
|
| /external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| D | ExecutionSequencerTest.java | 94 ListenableFuture<Boolean> future2 = in testCancellationMultipleThreads() local
121 ListenableFuture<Boolean> future2 = in testSecondTaskWaitsForFirstEvenIfCancelled() local
|
| D | AbstractFutureTest.java | 233 SettableFuture<Object> future2 = SettableFuture.create(); in testToString_oom() local
|
| /external/connectedappssdk/tests/robotests/src/test/java/com/google/android/enterprise/connectedapps/internal/ |
| D | CrossProfileCallbackMultiMergerTest.java | 215 ListenableFuture<String> future2 = Futures.submit(() -> "World", executorWithThread2); in listenableFuturesCompletingOnSeparateThreads() local
241 ListenableFuture<String> future2 = in listenableFuturesCompletingWithErrorsOnSeparateThreads() local
|
| /external/rust/crates/tokio/tests/ |
| D | sync_notify.rs | 207 let mut future2 = 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 | 244 final Future<byte[]> future2 = runAsync(new SSLServerSessionIdCallable(server2)); in test_SSLSocket_confirmSessionReuse() local
|
| /external/conscrypt/common/src/test/java/org/conscrypt/javax/net/ssl/ |
| D | SSLSocketVersionCompatibilityTest.java | 242 final Future<byte[]> future2 = runAsync(new SSLServerSessionIdCallable(server2)); in test_SSLSocket_confirmSessionReuse() local
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ManagedChannelImplTest.java | 2790 ListenableFuture<Void> future2 = ClientCalls.futureUnaryCall(call2, null); in badServiceConfigIsRecoverable() local
|