| /external/rust/crates/futures/tests/ |
| D | macro_comma_support.rs | 37 let future1 = async { 1 }; in join() localVariable
52 let future1 = async { 1 }.never_error(); in try_join() localVariable
|
| D | try_join.rs | 21 let future1 = async { Ok::<(), Never>(()) }; in try_join_never_error() localVariable
31 let future1 = async { Err::<Never, ()>(()) }; in try_join_never_ok() localVariable
|
| D | shared.rs | 97 let future1 = future::lazy(move |_| { in drop_in_poll() localVariable
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | ClosingFuture.java | 441 ClosingFuture<?> future1, ClosingFuture<?>... moreFutures) { in whenAllComplete()
467 ClosingFuture<V1> future1, ClosingFuture<V2> future2) { in whenAllSucceed()
482 ClosingFuture<V1> future1, ClosingFuture<V2> future2, ClosingFuture<V3> future3) { in whenAllSucceed()
497 ClosingFuture<V1> future1, in whenAllSucceed()
515 ClosingFuture<V1> future1, in whenAllSucceed()
531 ClosingFuture<?> future1, in whenAllSucceed()
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | ClosingFuture.java | 442 ClosingFuture<?> future1, ClosingFuture<?>... moreFutures) { in whenAllComplete()
468 ClosingFuture<V1> future1, ClosingFuture<V2> future2) { in whenAllSucceed()
483 ClosingFuture<V1> future1, ClosingFuture<V2> future2, ClosingFuture<V3> future3) { in whenAllSucceed()
498 ClosingFuture<V1> future1, in whenAllSucceed()
516 ClosingFuture<V1> future1, in whenAllSucceed()
532 ClosingFuture<?> future1, in whenAllSucceed()
|
| /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/protobuf/ruby/ext/google/protobuf_c/ |
| D | upb.h | 712 void *future1; variable
|
| /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
|