| /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/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | ClosingFuture.java | 468 ClosingFuture<V1> future1, ClosingFuture<V2> future2) { in whenAllSucceed() argument
469 return new Combiner2<>(future1, future2); in whenAllSucceed()
483 ClosingFuture<V1> future1, ClosingFuture<V2> future2, ClosingFuture<V3> future3) { in whenAllSucceed() argument
484 return new Combiner3<>(future1, future2, future3); in whenAllSucceed()
499 ClosingFuture<V2> future2, in whenAllSucceed() argument
502 return new Combiner4<>(future1, future2, future3, future4); in whenAllSucceed()
517 ClosingFuture<V2> future2, in whenAllSucceed() argument
521 return new Combiner5<>(future1, future2, future3, future4, future5); in whenAllSucceed()
533 ClosingFuture<?> future2, in whenAllSucceed() argument
540 FluentIterable.of(future1, future2, future3, future4, future5, future6) in whenAllSucceed()
[all …]
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | ClosingFuture.java | 467 ClosingFuture<V1> future1, ClosingFuture<V2> future2) { in whenAllSucceed() argument
468 return new Combiner2<>(future1, future2); in whenAllSucceed()
482 ClosingFuture<V1> future1, ClosingFuture<V2> future2, ClosingFuture<V3> future3) { in whenAllSucceed() argument
483 return new Combiner3<>(future1, future2, future3); in whenAllSucceed()
498 ClosingFuture<V2> future2, in whenAllSucceed() argument
501 return new Combiner4<>(future1, future2, future3, future4); in whenAllSucceed()
516 ClosingFuture<V2> future2, in whenAllSucceed() argument
520 return new Combiner5<>(future1, future2, future3, future4, future5); in whenAllSucceed()
532 ClosingFuture<?> future2, in whenAllSucceed() argument
539 FluentIterable.of(future1, future2, future3, future4, future5, future6) in whenAllSucceed()
[all …]
|
| /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()
87 …ert_future::<Either<(A::Output, B), (B::Output, A)>, _>(Select { 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()
56 >, _>(TrySelect { inner: Some((future1, future2)) }) in try_select()
|
| /external/rust/crates/futures/tests/ |
| D | try_join.rs | 22 let future2 = async { Ok::<(), Never>(()) }; in try_join_never_error() localVariable
23 try_join!(future1, future2) in try_join_never_error()
32 let future2 = async { Err::<Never, ()>(()) }; in try_join_never_ok() localVariable
33 try_join!(future1, future2) in try_join_never_ok()
|
| D | macro_comma_support.rs | 38 let future2 = async { 2 }; in join() localVariable
39 join!(future1, future2,); in join()
53 let future2 = async { 2 }.never_error(); in try_join() localVariable
54 try_join!(future1, future2,) in try_join()
|
| D | shared.rs | 103 let future2 = LocalFutureObj::new(Box::new(future1.clone())); in drop_in_poll() localVariable
104 slot1.replace(Some(future2)); in drop_in_poll()
|
| /external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| D | FuturesTest.java | 2164 SettableFuture<String> future2 = SettableFuture.create();
2167 ListenableFuture<List<String>> compound = allAsList(future1, future2, future3);
2177 future2.set(DATA2);
2210 SettableFuture<String> future2 = SettableFuture.create();
2212 ListenableFuture<List<String>> compound = allAsList(future1, future2);
2220 assertFalse(future2.isDone());
2246 ListenableFuture<String> future2 = immediateFuture("results");
2247 ListenableFuture<List<String>> compound = allAsList(ImmutableList.of(future1, future2));
2260 ListenableFuture<String> future2 = immediateFuture("results");
2261 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 | 234 SettableFuture<Object> future2 = SettableFuture.create(); in testToString_oom() local
250 future2.set(list); in testToString_oom()
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | FuturesTest.java | 2164 SettableFuture<String> future2 = SettableFuture.create();
2167 ListenableFuture<List<String>> compound = allAsList(future1, future2, future3);
2177 future2.set(DATA2);
2210 SettableFuture<String> future2 = SettableFuture.create();
2212 ListenableFuture<List<String>> compound = allAsList(future1, future2);
2220 assertFalse(future2.isDone());
2246 ListenableFuture<String> future2 = immediateFuture("results");
2247 ListenableFuture<List<String>> compound = allAsList(ImmutableList.of(future1, future2));
2260 ListenableFuture<String> future2 = immediateFuture("results");
2261 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 | 234 SettableFuture<Object> future2 = SettableFuture.create(); in testToString_oom() local
250 future2.set(list); in testToString_oom()
|
| /external/python/futures/ |
| D | test_futures.py | 300 future2 = self.executor.submit(time.sleep, 1.5)
303 [CANCELLED_FUTURE, future1, future2],
307 self.assertEqual(set([CANCELLED_FUTURE, future2]), not_done)
323 future2 = self.executor.submit(sleep_and_raise, 1.5)
327 [future1, future2, future3],
330 self.assertEqual(set([future1, future2]), finished)
335 future2 = self.executor.submit(time.sleep, 1.5)
341 future1, future2],
347 self.assertEqual(set([CANCELLED_FUTURE, future2]), pending)
361 future2 = self.executor.submit(mul, 2, 21)
[all …]
|
| /external/python/cpython3/Lib/test/ |
| D | test_concurrent_futures.py | 567 future2 = self.executor.submit(time.sleep, 1.5)
570 [CANCELLED_FUTURE, future1, future2],
574 self.assertEqual(set([CANCELLED_FUTURE, future2]), not_done)
590 future2 = self.executor.submit(sleep_and_raise, 1.5)
594 [future1, future2, future3],
597 self.assertEqual(set([future1, future2]), finished)
602 future2 = self.executor.submit(time.sleep, 1.5)
608 future1, future2],
614 self.assertEqual(set([CANCELLED_FUTURE, future2]), pending)
628 future2 = self.executor.submit(mul, 2, 21)
[all …]
|
| /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/kotlinx.coroutines/integration/kotlinx-coroutines-jdk8/ |
| D | README.md | 34 val future2 = loadImageAsync(name2) // start loading second image
35 combineImages(future1.await(), future2.await()) // wait for both, combine, and return result
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_proactor_events.py | 805 future2 = mock.Mock()
808 sock2.fileno(): future2
816 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()
|
| /external/protobuf/ruby/ext/google/protobuf_c/ |
| D | upb.h | 713 void *future2; variable
|