| /external/rust/crates/tokio/src/future/ |
| D | try_join.rs | 10 future2: F2, in try_join3()
20 future2: maybe_done(future2), in try_join3()
35 future2: MaybeDone<F2>,
60 if me.future2.as_mut().poll(cx).is_pending() { in poll()
62 } else if me.future2.as_mut().output_mut().unwrap().is_err() { in poll()
63 return Poll::Ready(Err(me.future2.take_output().unwrap().err().unwrap())); in poll()
75 me.future2.take_output().unwrap().ok().unwrap(), in poll()
|
| /external/rust/crates/futures-util/src/future/ |
| D | join.rs | 111 pub fn join<Fut1, Fut2>(future1: Fut1, future2: Fut2) -> Join<Fut1, Fut2> in join()
116 let f = Join::new(future1, future2); in join()
138 future2: Fut2, in join3()
146 let f = Join3::new(future1, future2, future3); in join3()
169 future2: Fut2, in join4()
179 let f = Join4::new(future1, future2, future3, future4); in join4()
203 future2: Fut2, in join5()
215 let f = Join5::new(future1, future2, future3, future4, future5); in join5()
|
| D | try_join.rs | 148 pub fn try_join<Fut1, Fut2>(future1: Fut1, future2: Fut2) -> TryJoin<Fut1, Fut2> in try_join()
153 assert_future::<Result<(Fut1::Ok, Fut2::Ok), Fut1::Error>, _>(TryJoin::new(future1, future2)) in try_join()
174 future2: Fut2, in try_join3()
183 future1, future2, future3, in try_join3()
206 future2: Fut2, in try_join4()
217 TryJoin4::new(future1, future2, future3, future4), in try_join4()
241 future2: Fut2, in try_join5()
254 TryJoin5::new(future1, future2, future3, future4, future5), in try_join5()
|
| D | select.rs | 84 pub fn select<A, B>(future1: A, future2: B) -> Select<A, B> in select()
90 inner: Some((future1, future2)), in select()
|
| D | try_select.rs | 50 pub fn try_select<A, B>(future1: A, future2: B) -> TrySelect<A, B> in try_select()
58 >(TrySelect { inner: Some((future1, future2)) }) in try_select()
|
| /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() argument
501 return new Combiner2<>(future1, future2); in whenAllSucceed()
517 ClosingFuture<V1> future1, ClosingFuture<V2> future2, ClosingFuture<V3> future3) { in whenAllSucceed() argument
518 return new Combiner3<>(future1, future2, future3); in whenAllSucceed()
538 ClosingFuture<V2> future2, in whenAllSucceed() argument
541 return new Combiner4<>(future1, future2, future3, future4); in whenAllSucceed()
562 ClosingFuture<V2> future2, in whenAllSucceed() argument
566 return new Combiner5<>(future1, future2, future3, future4, future5); in whenAllSucceed()
578 ClosingFuture<?> future2, in whenAllSucceed() argument
585 FluentIterable.of(future1, future2, future3, future4, future5, future6) in whenAllSucceed()
[all …]
|
| /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() argument
499 return new Combiner2<>(future1, future2); in whenAllSucceed()
515 ClosingFuture<V1> future1, ClosingFuture<V2> future2, ClosingFuture<V3> future3) { in whenAllSucceed() argument
516 return new Combiner3<>(future1, future2, future3); in whenAllSucceed()
536 ClosingFuture<V2> future2, in whenAllSucceed() argument
539 return new Combiner4<>(future1, future2, future3, future4); in whenAllSucceed()
560 ClosingFuture<V2> future2, in whenAllSucceed() argument
564 return new Combiner5<>(future1, future2, future3, future4, future5); in whenAllSucceed()
576 ClosingFuture<?> future2, in whenAllSucceed() argument
583 FluentIterable.of(future1, future2, future3, future4, future5, future6) in whenAllSucceed()
[all …]
|
| /external/rust/crates/futures/tests/ |
| D | try_join.rs | 21 let future2 = async { Ok::<(), Never>(()) }; in try_join_never_error() localVariable
22 try_join!(future1, future2) in try_join_never_error()
31 let future2 = async { Err::<Never, ()>(()) }; in try_join_never_ok() localVariable
32 try_join!(future1, future2) in try_join_never_ok()
|
| D | macro_comma_support.rs | 30 let future2 = async { 2 }; in join() localVariable
31 join!(future1, future2,); in join()
39 let future2 = async { 2 }.never_error(); in try_join() localVariable
40 try_join!(future1, future2,) in try_join()
|
| D | future_shared.rs | 94 let future2 = LocalFutureObj::new(Box::new(future1.clone())); in drop_in_poll() localVariable
95 slot1.replace(Some(future2)); in drop_in_poll()
|
| /external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| D | FuturesTest.java | 2149 SettableFuture<String> future2 = SettableFuture.create();
2152 ListenableFuture<List<String>> compound = allAsList(future1, future2, future3);
2162 future2.set(DATA2);
2195 SettableFuture<String> future2 = SettableFuture.create();
2197 ListenableFuture<List<String>> compound = allAsList(future1, future2);
2205 assertFalse(future2.isDone());
2231 ListenableFuture<String> future2 = immediateFuture("results");
2232 ListenableFuture<List<String>> compound = allAsList(ImmutableList.of(future1, future2));
2245 ListenableFuture<String> future2 = immediateFuture("results");
2246 ListenableFuture<List<String>> compound = allAsList(ImmutableList.of(future1, future2));
[all …]
|
| D | ExecutionSequencerTest.java | 94 ListenableFuture<Boolean> future2 = in testCancellationMultipleThreads() local
109 assertThat(future2.isDone()).isFalse(); in testCancellationMultipleThreads()
115 assertThat(getDone(future2)).isFalse(); in testCancellationMultipleThreads()
121 ListenableFuture<Boolean> future2 = in testSecondTaskWaitsForFirstEvenIfCancelled() local
141 assertThat(future2.isDone()).isFalse(); in testSecondTaskWaitsForFirstEvenIfCancelled()
147 assertThat(getDone(future2)).isFalse(); in testSecondTaskWaitsForFirstEvenIfCancelled()
|
| D | AbstractFutureTest.java | 233 SettableFuture<Object> future2 = SettableFuture.create(); in testToString_oom() local
249 future2.set(list); in testToString_oom()
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | FuturesTest.java | 2149 SettableFuture<String> future2 = SettableFuture.create();
2152 ListenableFuture<List<String>> compound = allAsList(future1, future2, future3);
2162 future2.set(DATA2);
2195 SettableFuture<String> future2 = SettableFuture.create();
2197 ListenableFuture<List<String>> compound = allAsList(future1, future2);
2205 assertFalse(future2.isDone());
2231 ListenableFuture<String> future2 = immediateFuture("results");
2232 ListenableFuture<List<String>> compound = allAsList(ImmutableList.of(future1, future2));
2245 ListenableFuture<String> future2 = immediateFuture("results");
2246 ListenableFuture<List<String>> compound = allAsList(ImmutableList.of(future1, future2));
[all …]
|
| D | ExecutionSequencerTest.java | 94 ListenableFuture<Boolean> future2 = in testCancellationMultipleThreads() local
109 assertThat(future2.isDone()).isFalse(); in testCancellationMultipleThreads()
115 assertThat(getDone(future2)).isFalse(); in testCancellationMultipleThreads()
121 ListenableFuture<Boolean> future2 = in testSecondTaskWaitsForFirstEvenIfCancelled() local
141 assertThat(future2.isDone()).isFalse(); in testSecondTaskWaitsForFirstEvenIfCancelled()
147 assertThat(getDone(future2)).isFalse(); in testSecondTaskWaitsForFirstEvenIfCancelled()
|
| D | AbstractFutureTest.java | 233 SettableFuture<Object> future2 = SettableFuture.create(); in testToString_oom() local
249 future2.set(list); in testToString_oom()
|
| /external/python/cpython3/Lib/test/ |
| D | test_concurrent_futures.py | 599 future2 = self.executor.submit(time.sleep, 1.5)
602 [CANCELLED_FUTURE, future1, future2],
606 self.assertEqual(set([CANCELLED_FUTURE, future2]), not_done)
622 future2 = self.executor.submit(sleep_and_raise, 1.5)
626 [future1, future2, future3],
629 self.assertEqual(set([future1, future2]), finished)
634 future2 = self.executor.submit(time.sleep, 1.5)
640 future1, future2],
646 self.assertEqual(set([CANCELLED_FUTURE, future2]), pending)
660 future2 = self.executor.submit(mul, 2, 21)
[all …]
|
| /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
223 future2, new MergerFutureCallback<String>(profile1, merger), directExecutor()); in listenableFuturesCompletingOnSeparateThreads()
241 ListenableFuture<String> future2 = in listenableFuturesCompletingWithErrorsOnSeparateThreads() local
254 future2, new MergerFutureCallback<String>(profile1, merger), directExecutor()); in listenableFuturesCompletingWithErrorsOnSeparateThreads()
|
| /external/rust/crates/tokio/tests/ |
| D | sync_notify.rs | 207 let mut future2 = spawn(notify.notified()); in test_enable_consumes_permit() localVariable
208 future2.enter(|_, fut| assert!(!fut.enable())); in test_enable_consumes_permit()
|
| /external/kotlinx.coroutines/integration/kotlinx-coroutines-guava/ |
| D | README.md | 33 val future2 = loadImageAsync(name2) // start loading second image
34 combineImages(future1.await(), future2.await()) // wait for both, combine, and return result
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_proactor_events.py | 829 future2 = mock.Mock()
832 sock2.fileno(): future2
840 self.assertFalse(future2.cancel.called)
|
| /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
249 final byte[] serverSessionId2 = future2.get(); in test_SSLSocket_confirmSessionReuse()
|
| /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
247 final byte[] serverSessionId2 = future2.get(); in test_SSLSocket_confirmSessionReuse()
|
| /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
2796 future2.get(); in badServiceConfigIsRecoverable()
|