| /external/rust/crates/futures-task/src/ |
| D | future_obj.rs | 4 future::Future,
17 future: *mut (dyn Future<Output = T> + 'static),
18 drop_fn: unsafe fn(*mut (dyn Future<Output = T> + 'static)),
29 unsafe fn remove_future_lifetime<'a, T>(ptr: *mut (dyn Future<Output = T> + 'a)) in remove_future_lifetime()
30 -> *mut (dyn Future<Output = T> + 'static) in remove_future_lifetime()
36 unsafe fn remove_drop_lifetime<'a, T>(ptr: unsafe fn (*mut (dyn Future<Output = T> + 'a))) in remove_drop_lifetime()
37 -> unsafe fn(*mut (dyn Future<Output = T> + 'static)) in remove_drop_lifetime()
80 impl<T> Future for LocalFutureObj<'_, T> {
128 impl<T> Future for FutureObj<'_, T> {
158 fn into_raw(self) -> *mut (dyn Future<Output = T> + 'a); in into_raw()
[all …]
|
| /external/crosvm/cros_async/src/ |
| D | lib.rs | 89 use std::future::Future;
112 impl<T> Future for Empty<T> {
136 pub fn run_one<F: Future>(fut: F) -> Result<F::Output> { in run_one()
154 pub fn run_one_uring<F: Future>(fut: F) -> Result<F::Output> { in run_one_uring()
170 pub fn run_one_poll<F: Future>(fut: F) -> Result<F::Output> { in run_one_poll()
197 pub async fn select2<F1: Future + Unpin, F2: Future + Unpin>( in select2()
227 pub async fn select3<F1: Future + Unpin, F2: Future + Unpin, F3: Future + Unpin>( in select3()
260 F1: Future + Unpin, in select4()
261 F2: Future + Unpin, in select4()
262 F3: Future + Unpin, in select4()
[all …]
|
| D | select.rs | 8 use std::future::Future;
14 pub enum SelectResult<F: Future> {
29 pub(crate) struct $Select<$($Fut: Future + Unpin),*> {
34 impl<$($Fut: Future + Unpin),*> $Select<$($Fut),*> {
44 impl<$($Fut: Future + Unpin),*> Future for $Select<$($Fut),*> { impl
59 MaybeDone::Future(f) => SelectResult::Pending(f),
|
| /external/python/cpython3/Doc/library/ |
| D | asyncio-future.rst | 15 *Future* objects are used to bridge **low-level callback-based code**
19 Future Functions
26 * an instance of :class:`asyncio.Future`,
28 * a Future-like object with a ``_asyncio_future_blocking``
38 * *obj* argument as is, if *obj* is a :class:`Future`,
39 a :class:`Task`, or a Future-like object (:func:`isfuture`
63 Wrap a :class:`concurrent.futures.Future` object in a
64 :class:`asyncio.Future` object.
67 Future Object
70 .. class:: Future(\*, loop=None)
[all …]
|
| /external/rust/crates/tokio/src/net/ |
| D | addr.rs | 25 pub(crate) fn to_socket_addrs<T>(arg: T) -> T::Future
42 type Future = T::Future; typedef
44 fn to_socket_addrs(&self, _: sealed::Internal) -> Self::Future { in to_socket_addrs() argument
55 type Future = ReadyFuture<Self::Iter>; typedef
57 fn to_socket_addrs(&self, _: sealed::Internal) -> Self::Future { in to_socket_addrs() argument
69 type Future = ReadyFuture<Self::Iter>; typedef
71 fn to_socket_addrs(&self, _: sealed::Internal) -> Self::Future { in to_socket_addrs() argument
82 type Future = ReadyFuture<Self::Iter>; typedef
84 fn to_socket_addrs(&self, _: sealed::Internal) -> Self::Future { in to_socket_addrs() argument
95 type Future = ReadyFuture<Self::Iter>; typedef
[all …]
|
| /external/rust/crates/futures-util/src/future/ |
| D | join.rs | 7 use futures_core::future::{FusedFuture, Future};
19 pub struct $Join<$($Fut: Future),*> {
27 $Fut: Future + fmt::Debug,
38 impl<$($Fut: Future),*> $Join<$($Fut),*> {
46 impl<$($Fut: Future),*> Future for $Join<$($Fut),*> { impl
113 Fut1: Future, in join() argument
114 Fut2: Future, in join() argument
142 Fut1: Future, in join3() argument
143 Fut2: Future, in join3() argument
144 Fut3: Future, in join3() argument
[all …]
|
| D | maybe_done.rs | 6 use futures_core::future::{FusedFuture, Future};
14 pub enum MaybeDone<Fut: Future> {
16 Future(/* #[pin] */ Fut), enumerator
24 impl<Fut: Future + Unpin> Unpin for MaybeDone<Fut> {}
43 pub fn maybe_done<Fut: Future>(future: Fut) -> MaybeDone<Fut> { in maybe_done()
44 assert_future::<(), _>(MaybeDone::Future(future)) in maybe_done()
47 impl<Fut: Future> MaybeDone<Fut> {
68 Self::Future(_) | Self::Gone => return None, in take_output()
79 impl<Fut: Future> FusedFuture for MaybeDone<Fut> {
82 Self::Future(_) => false, in is_terminated()
[all …]
|
| D | join_all.rs | 5 use core::future::Future;
28 F: Future,
35 F: Future + fmt::Debug,
85 I::Item: Future, in join_all() argument
87 let elems: Box<[_]> = i.into_iter().map(MaybeDone::Future).collect(); in join_all()
88 assert_future::<Vec<<I::Item as Future>::Output>, _>(JoinAll { elems: elems.into() }) in join_all()
91 impl<F> Future for JoinAll<F>
93 F: Future,
118 impl<F: Future> FromIterator<F> for JoinAll<F> {
|
| D | select.rs | 3 use futures_core::future::{Future, FusedFuture};
85 where A: Future + Unpin, B: Future + Unpin in select()
90 impl<A, B> Future for Select<A, B>
92 A: Future + Unpin,
93 B: Future + Unpin,
114 A: Future + Unpin,
115 B: Future + Unpin,
|
| D | try_maybe_done.rs | 6 use futures_core::future::{FusedFuture, Future, TryFuture};
16 Future(/* #[pin] */ Fut), enumerator
29 assert_future::<Result<(), Fut::Error>, _>(TryMaybeDone::Future(future)) in try_maybe_done()
53 Self::Future(_) | Self::Gone => return None, in take_output()
67 Self::Future(_) => false, in is_terminated()
73 impl<Fut: TryFuture> Future for TryMaybeDone<Fut> {
79 TryMaybeDone::Future(f) => { in poll()
|
| /external/rust/crates/tokio/src/future/ |
| D | maybe_done.rs | 3 use std::future::Future;
10 pub enum MaybeDone<Fut: Future> {
12 Future(Fut), enumerator
21 impl<Fut: Future + Unpin> Unpin for MaybeDone<Fut> {}
24 pub fn maybe_done<Fut: Future>(future: Fut) -> MaybeDone<Fut> { in maybe_done()
25 MaybeDone::Future(future) in maybe_done()
28 impl<Fut: Future> MaybeDone<Fut> {
51 MaybeDone::Future(_) | MaybeDone::Gone => return None, in take_output()
62 impl<Fut: Future> Future for MaybeDone<Fut> {
68 MaybeDone::Future(a) => ready!(Pin::new_unchecked(a).poll(cx)), in poll()
|
| D | try_join.rs | 4 use std::future::Future;
14 F1: Future<Output = Result<T1, E>>, in try_join3()
15 F2: Future<Output = Result<T2, E>>, in try_join3()
16 F3: Future<Output = Result<T3, E>>, in try_join3()
28 F1: Future,
29 F2: Future,
30 F3: Future,
41 impl<T1, F1, T2, F2, T3, F3, E> Future for TryJoin3<F1, F2, F3>
43 F1: Future<Output = Result<T1, E>>,
44 F2: Future<Output = Result<T2, E>>,
[all …]
|
| /external/rust/crates/futures-util/src/future/future/ |
| D | shared.rs | 2 use futures_core::future::{FusedFuture, Future};
14 pub struct Shared<Fut: Future> {
19 struct Inner<Fut: Future> {
30 pub struct WeakShared<Fut: Future>(Weak<Inner<Fut>>);
34 impl<Fut: Future> Unpin for Shared<Fut> {}
36 impl<Fut: Future> fmt::Debug for Shared<Fut> {
45 impl<Fut: Future> fmt::Debug for Inner<Fut> {
51 impl<Fut: Future> fmt::Debug for WeakShared<Fut> {
57 enum FutureOrOutput<Fut: Future> {
58 Future(Fut), enumerator
[all …]
|
| D | mod.rs | 17 future::Future,
32 flatten::Flatten<F, <F as Future>::Output>
33 ): Debug + Future + FusedFuture + New[|x: F| flatten::Flatten::new(x)]
34 where F: Future
40 flatten::Flatten<F, <F as Future>::Output>
42 where F: Future
52 ): Debug + Future + FusedFuture + New[|x: Fut, f: F| map::Map::new(x, f)]
66 ): Debug + Future + FusedFuture + New[|x: Fut| Map::new(x, into_fn())]
73 ): Debug + Future + FusedFuture + New[|x: Fut1, y: F| flatten::Flatten::new(Map::new(x, y))]
80 ): Debug + Future + FusedFuture + New[|x: Fut, f: F| map::Map::new(x, inspect_fn(f))]
[all …]
|
| D | flatten.rs | 2 use futures_core::future::{FusedFuture, Future};
27 where Fut: Future,
28 Fut::Output: Future,
38 impl<Fut> Future for Flatten<Fut, Fut::Output>
39 where Fut: Future,
40 Fut::Output: Future,
42 type Output = <Fut::Output as Future>::Output;
63 where Fut: Future,
75 where Fut: Future,
104 Fut: Future,
|
| D | remote_handle.rs | 5 future::Future,
57 impl<T: 'static> Future for RemoteHandle<T> {
71 type SendMsg<Fut> = Result<<Fut as Future>::Output, Box<(dyn Any + Send + 'static)>>;
78 pub struct Remote<Fut: Future> {
86 impl<Fut: Future + fmt::Debug> fmt::Debug for Remote<Fut> {
94 impl<Fut: Future> Future for Remote<Fut> {
116 pub(super) fn remote_handle<Fut: Future>(future: Fut) -> (Remote<Fut>, RemoteHandle<Fut::Output>) { in remote_handle()
|
| /external/rust/crates/futures-util/src/stream/ |
| D | futures_ordered.rs | 7 use futures_core::future::Future;
47 impl<T> Future for OrderWrapper<T>
49 T: Future,
98 pub struct FuturesOrdered<T: Future> {
105 impl<T: Future> Unpin for FuturesOrdered<T> {}
107 impl<Fut: Future> FuturesOrdered<Fut> {
151 impl<Fut: Future> Default for FuturesOrdered<Fut> {
157 impl<Fut: Future> Stream for FuturesOrdered<Fut> {
192 impl<Fut: Future> Debug for FuturesOrdered<Fut> {
198 impl<Fut: Future> FromIterator<Fut> for FuturesOrdered<Fut> {
[all …]
|
| /external/rust/crates/criterion/src/ |
| D | async_executor.rs | 14 use std::future::Future;
22 fn block_on<T>(&self, future: impl Future<Output = T>) -> T; in block_on()
30 fn block_on<T>(&self, future: impl Future<Output = T>) -> T { in block_on()
40 fn block_on<T>(&self, future: impl Future<Output = T>) -> T { in block_on()
47 fn block_on<T>(&self, future: impl Future<Output = T>) -> T { in block_on()
53 fn block_on<T>(&self, future: impl Future<Output = T>) -> T { in block_on()
63 fn block_on<T>(&self, future: impl Future<Output = T>) -> T { in block_on()
|
| /external/llvm/lib/Support/ |
| D | ThreadPool.cpp | 88 auto Future = PackagedTask.get_future(); in asyncImpl() local
99 return Future.share(); in asyncImpl()
142 auto Future = std::async(std::launch::deferred, std::move(Task)).share(); in asyncImpl() local
145 PackagedTaskTy PackagedTask([Future]() { Future.get(); }); in asyncImpl()
147 auto Future = std::async(std::launch::deferred, std::move(Task), false).share(); in asyncImpl()
148 PackagedTaskTy PackagedTask([Future](bool) -> bool { Future.get(); return false; }); in asyncImpl()
151 return Future; in asyncImpl()
|
| /external/rust/crates/futures-core/src/ |
| D | future.rs | 8 pub use core::future::Future;
13 pub type BoxFuture<'a, T> = Pin<alloc::boxed::Box<dyn Future<Output = T> + Send + 'a>>;
17 pub type LocalBoxFuture<'a, T> = Pin<alloc::boxed::Box<dyn Future<Output = T> + 'a>>;
27 pub trait FusedFuture: Future {
49 use super::Future;
53 impl<F, T, E> Sealed for F where F: ?Sized + Future<Output = Result<T, E>> {}
58 pub trait TryFuture: Future + private_try_future::Sealed {
77 where F: ?Sized + Future<Output = Result<T, E>>
|
| /external/rust/crates/tokio/src/signal/ |
| D | reusable_box.rs | 2 use std::future::Future;
14 boxed: NonNull<dyn Future<Output = T> + Send>,
21 F: Future<Output = T> + Send + 'static, in new()
23 let boxed: Box<dyn Future<Output = T> + Send> = Box::new(future); in new()
39 F: Future<Output = T> + Send + 'static, in set()
53 F: Future<Output = T> + Send + 'static, in try_set()
57 let dyn_future: &(dyn Future<Output = T> + Send) = unsafe { self.boxed.as_ref() }; in try_set()
81 F: Future<Output = T> + Send + 'static, in set_same_layout()
107 pub(crate) fn get_pin(&mut self) -> Pin<&mut (dyn Future<Output = T> + Send)> { in get_pin()
119 impl<T> Future for ReusableBoxFuture<T> {
[all …]
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | JdkFutureAdapters.java | 24 import java.util.concurrent.Future;
52 public static <V> ListenableFuture<V> listenInPoolThread(Future<V> future) { in listenInPoolThread()
79 public static <V> ListenableFuture<V> listenInPoolThread(Future<V> future, Executor executor) { in listenInPoolThread()
117 private final Future<V> delegate;
119 ListenableFutureAdapter(Future<V> delegate) { in ListenableFutureAdapter()
123 ListenableFutureAdapter(Future<V> delegate, Executor adapterExecutor) { in ListenableFutureAdapter()
129 protected Future<V> delegate() { in delegate()
|
| D | ForwardingFuture.java | 22 import java.util.concurrent.Future;
38 public abstract class ForwardingFuture<V> extends ForwardingObject implements Future<V> {
43 protected abstract Future<? extends V> delegate(); in delegate()
79 private final Future<V> delegate;
81 protected SimpleForwardingFuture(Future<V> delegate) { in SimpleForwardingFuture()
86 protected final Future<V> delegate() { in delegate()
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | JdkFutureAdapters.java | 24 import java.util.concurrent.Future;
52 public static <V> ListenableFuture<V> listenInPoolThread(Future<V> future) { in listenInPoolThread()
79 public static <V> ListenableFuture<V> listenInPoolThread(Future<V> future, Executor executor) { in listenInPoolThread()
117 private final Future<V> delegate;
119 ListenableFutureAdapter(Future<V> delegate) { in ListenableFutureAdapter()
123 ListenableFutureAdapter(Future<V> delegate, Executor adapterExecutor) { in ListenableFutureAdapter()
129 protected Future<V> delegate() { in delegate()
|
| D | ForwardingFuture.java | 22 import java.util.concurrent.Future;
38 public abstract class ForwardingFuture<V> extends ForwardingObject implements Future<V> {
43 protected abstract Future<? extends V> delegate(); in delegate()
79 private final Future<V> delegate;
81 protected SimpleForwardingFuture(Future<V> delegate) { in SimpleForwardingFuture()
86 protected final Future<V> delegate() { in delegate()
|