Home
last modified time | relevance | path

Searched refs:Fut (Results 1 – 25 of 108) sorted by relevance

12345

/external/rust/crates/futures-util/src/stream/futures_unordered/
Diter.rs10 pub struct IterPinMut<'a, Fut> {
11 pub(super) task: *const Task<Fut>,
13 pub(super) _marker: PhantomData<&'a mut FuturesUnordered<Fut>>,
18 pub struct IterMut<'a, Fut: Unpin>(pub(super) IterPinMut<'a, Fut>);
22 pub struct IterPinRef<'a, Fut> {
23 pub(super) task: *const Task<Fut>,
25 pub(super) pending_next_all: *mut Task<Fut>,
26 pub(super) _marker: PhantomData<&'a FuturesUnordered<Fut>>,
31 pub struct Iter<'a, Fut: Unpin>(pub(super) IterPinRef<'a, Fut>);
35 pub struct IntoIter<Fut: Unpin> {
[all …]
Dmod.rs58 pub struct FuturesUnordered<Fut> {
59 ready_to_run_queue: Arc<ReadyToRunQueue<Fut>>,
60 head_all: AtomicPtr<Task<Fut>>,
64 unsafe impl<Fut: Send> Send for FuturesUnordered<Fut> {}
65 unsafe impl<Fut: Sync> Sync for FuturesUnordered<Fut> {}
66 impl<Fut> Unpin for FuturesUnordered<Fut> {}
107 impl<Fut> Default for FuturesUnordered<Fut> {
113 impl<Fut> FuturesUnordered<Fut> {
166 pub fn push(&self, future: Fut) { in push() argument
195 pub fn iter(&self) -> Iter<'_, Fut> in iter()
[all …]
Dtask.rs10 pub(super) struct Task<Fut> {
12 pub(super) future: UnsafeCell<Option<Fut>>,
16 pub(super) next_all: AtomicPtr<Task<Fut>>,
19 pub(super) prev_all: UnsafeCell<*const Task<Fut>>,
27 pub(super) next_ready_to_run: AtomicPtr<Task<Fut>>,
30 pub(super) ready_to_run_queue: Weak<ReadyToRunQueue<Fut>>,
46 unsafe impl<Fut> Send for Task<Fut> {}
47 unsafe impl<Fut> Sync for Task<Fut> {}
49 impl<Fut> ArcWake for Task<Fut> {
78 impl<Fut> Task<Fut> {
[all …]
/external/rust/crates/futures-util/src/future/future/
Dshared.rs16 pub struct Shared<Fut: Future> {
17 inner: Option<Arc<Inner<Fut>>>,
21 struct Inner<Fut: Future> {
22 future_or_output: UnsafeCell<FutureOrOutput<Fut>>,
32 pub struct WeakShared<Fut: Future>(Weak<Inner<Fut>>);
34 impl<Fut: Future> Clone for WeakShared<Fut> {
42 impl<Fut: Future> Unpin for Shared<Fut> {}
44 impl<Fut: Future> fmt::Debug for Shared<Fut> {
53 impl<Fut: Future> fmt::Debug for Inner<Fut> {
59 impl<Fut: Future> fmt::Debug for WeakShared<Fut> {
[all …]
Dflatten.rs26 impl<Fut> FusedFuture for Flatten<Fut, Fut::Output>
28 Fut: Future,
29 Fut::Output: Future,
39 impl<Fut> Future for Flatten<Fut, Fut::Output>
41 Fut: Future,
42 Fut::Output: Future,
44 type Output = <Fut::Output as Future>::Output;
64 impl<Fut> FusedStream for Flatten<Fut, Fut::Output>
66 Fut: Future,
67 Fut::Output: Stream,
[all …]
/external/crosvm/cros_async/src/
Dcomplete.rs23 ($Complete:ident, <$($Fut:ident),*>),
26 pub(crate) struct $Complete<$($Fut: Future),*> {
27 $($Fut: MaybeDone<$Fut>,)*
30 impl<$($Fut),*> $Complete<$($Fut),*>
32 $Fut: Future,
40 unsafe_pinned!($Fut: MaybeDone<$Fut>);
43 pub(crate) fn new($($Fut: $Fut),*) -> $Complete<$($Fut),*> {
45 let $Fut = maybe_done($Fut);
48 $($Fut),*
53 impl<$($Fut),*> Future for $Complete<$($Fut),*>
[all …]
Dselect.rs28 ($Select:ident, <$($Fut:ident),*>),
31 pub(crate) struct $Select<$($Fut: Future + Unpin),*> {
32 $($Fut: MaybeDone<$Fut>,)*
36 impl<$($Fut: Future + Unpin),*> $Select<$($Fut),*> {
38 pub(crate) fn new($($Fut: $Fut),*) -> $Select<$($Fut),*> {
40 $($Fut: maybe_done($Fut),)*
46 impl<$($Fut: Future + Unpin),*> Future for $Select<$($Fut),*> {
47 type Output = ($(SelectResult<$Fut>),*);
52 let $Fut = Pin::new(&mut self.$Fut);
55 complete |= self.$Fut.poll_unpin(cx).is_ready();
[all …]
/external/rust/crates/futures-util/src/future/try_future/
Dtry_flatten.rs26 impl<Fut> FusedFuture for TryFlatten<Fut, Fut::Ok>
28 Fut: TryFuture,
29 Fut::Ok: TryFuture<Error = Fut::Error>,
39 impl<Fut> Future for TryFlatten<Fut, Fut::Ok>
41 Fut: TryFuture,
42 Fut::Ok: TryFuture<Error = Fut::Error>,
44 type Output = Result<<Fut::Ok as TryFuture>::Ok, Fut::Error>;
67 impl<Fut> FusedStream for TryFlatten<Fut, Fut::Ok>
69 Fut: TryFuture,
70 Fut::Ok: TryStream<Error = Fut::Error>,
[all …]
Dmod.rs46 TryFlattenStream<Fut>(
47 try_flatten::TryFlatten<Fut, Fut::Ok>
48 ): Debug + Sink + Stream + FusedStream + New[|x: Fut| try_flatten::TryFlatten::new(x)]
49 where Fut: TryFuture
56 FlattenSink<Fut, Si>(
57 try_flatten::TryFlatten<Fut, Si>
58 ): Debug + Sink + Stream + FusedStream + New[|x: Fut| try_flatten::TryFlatten::new(x)]
77 ErrInto<Fut, E>(
78 MapErr<Fut, IntoFn<E>>
79 ): Debug + Future + FusedFuture + New[|x: Fut| MapErr::new(x, into_fn())]
[all …]
/external/rust/crates/tokio/src/task/
Dbuilder.rs86 pub fn spawn<Fut>(self, future: Fut) -> io::Result<JoinHandle<Fut::Output>> in spawn()
88 Fut: Future + Send + 'static, in spawn()
89 Fut::Output: Send + 'static, in spawn()
102 pub fn spawn_on<Fut>(self, future: Fut, handle: &Handle) -> io::Result<JoinHandle<Fut::Output>> in spawn_on() argument
104 Fut: Future + Send + 'static, in spawn_on()
105 Fut::Output: Send + 'static, in spawn_on()
125 pub fn spawn_local<Fut>(self, future: Fut) -> io::Result<JoinHandle<Fut::Output>> in spawn_local()
127 Fut: Future + 'static, in spawn_local()
128 Fut::Output: 'static, in spawn_local()
141 pub fn spawn_local_on<Fut>( in spawn_local_on()
[all …]
/external/rust/crates/futures-util/src/future/
Dtry_maybe_done.rs14 pub enum TryMaybeDone<Fut: TryFuture> {
16 Future(/* #[pin] */ Fut),
18 Done(Fut::Ok),
25 impl<Fut: TryFuture + Unpin> Unpin for TryMaybeDone<Fut> {}
28 pub fn try_maybe_done<Fut: TryFuture>(future: Fut) -> TryMaybeDone<Fut> { in try_maybe_done() argument
29 assert_future::<Result<(), Fut::Error>, _>(TryMaybeDone::Future(future)) in try_maybe_done()
32 impl<Fut: TryFuture> TryMaybeDone<Fut> {
38 pub fn output_mut(self: Pin<&mut Self>) -> Option<&mut Fut::Ok> { in output_mut()
50 pub fn take_output(self: Pin<&mut Self>) -> Option<Fut::Ok> { in take_output()
64 impl<Fut: TryFuture> FusedFuture for TryMaybeDone<Fut> {
[all …]
Djoin.rs14 ($Join:ident, <$($Fut:ident),*>),
19 pub struct $Join<$($Fut: Future),*> {
20 $(#[pin] $Fut: MaybeDone<$Fut>,)*
24 impl<$($Fut),*> fmt::Debug for $Join<$($Fut),*>
27 $Fut: Future + fmt::Debug,
28 $Fut::Output: fmt::Debug,
33 $(.field(stringify!($Fut), &self.$Fut))*
38 impl<$($Fut: Future),*> $Join<$($Fut),*> {
39 fn new($($Fut: $Fut),*) -> Self {
41 $($Fut: maybe_done($Fut)),*
[all …]
Dmaybe_done.rs14 pub enum MaybeDone<Fut: Future> {
16 Future(/* #[pin] */ Fut),
18 Done(Fut::Output),
24 impl<Fut: Future + Unpin> Unpin for MaybeDone<Fut> {}
43 pub fn maybe_done<Fut: Future>(future: Fut) -> MaybeDone<Fut> { in maybe_done() argument
47 impl<Fut: Future> MaybeDone<Fut> {
53 pub fn output_mut(self: Pin<&mut Self>) -> Option<&mut Fut::Output> { in output_mut()
65 pub fn take_output(self: Pin<&mut Self>) -> Option<Fut::Output> { in take_output()
79 impl<Fut: Future> FusedFuture for MaybeDone<Fut> {
88 impl<Fut: Future> Future for MaybeDone<Fut> {
/external/rust/crates/futures-util/src/stream/stream/
Dtake_until.rs16 pub struct TakeUntil<St: Stream, Fut: Future> {
22 fut: Option<Fut>,
24 fut_result: Option<Fut::Output>,
30 impl<St, Fut> fmt::Debug for TakeUntil<St, Fut>
34 Fut: Future + fmt::Debug,
41 impl<St, Fut> TakeUntil<St, Fut>
44 Fut: Future,
46 pub(super) fn new(stream: St, fut: Fut) -> Self { in new()
56 pub fn take_future(&mut self) -> Option<Fut> { in take_future() argument
100 pub fn take_result(&mut self) -> Option<Fut::Output> { in take_result()
[all …]
Dfilter_map.rs15 pub struct FilterMap<St, Fut, F> {
20 pending: Option<Fut>,
24 impl<St, Fut, F> fmt::Debug for FilterMap<St, Fut, F>
27 Fut: fmt::Debug,
37 impl<St, Fut, F> FilterMap<St, Fut, F>
40 F: FnMut(St::Item) -> Fut,
41 Fut: Future,
50 impl<St, Fut, F, T> FusedStream for FilterMap<St, Fut, F>
53 F: FnMut1<St::Item, Output = Fut>,
54 Fut: Future<Output = Option<T>>,
[all …]
Dthen.rs14 pub struct Then<St, Fut, F> {
18 future: Option<Fut>,
23 impl<St, Fut, F> fmt::Debug for Then<St, Fut, F>
26 Fut: fmt::Debug,
33 impl<St, Fut, F> Then<St, Fut, F>
36 F: FnMut(St::Item) -> Fut,
45 impl<St, Fut, F> FusedStream for Then<St, Fut, F>
48 F: FnMut(St::Item) -> Fut,
49 Fut: Future,
56 impl<St, Fut, F> Stream for Then<St, Fut, F>
[all …]
Dfor_each.rs12 pub struct ForEach<St, Fut, F> {
17 future: Option<Fut>,
21 impl<St, Fut, F> fmt::Debug for ForEach<St, Fut, F>
24 Fut: fmt::Debug,
34 impl<St, Fut, F> ForEach<St, Fut, F>
37 F: FnMut(St::Item) -> Fut,
38 Fut: Future<Output = ()>,
45 impl<St, Fut, F> FusedFuture for ForEach<St, Fut, F>
48 F: FnMut(St::Item) -> Fut,
49 Fut: Future<Output = ()>,
[all …]
Dskip_while.rs14 pub struct SkipWhile<St, Fut, F> where St: Stream {
19 pending_fut: Option<Fut>,
25 impl<St, Fut, F> fmt::Debug for SkipWhile<St, Fut, F>
29 Fut: fmt::Debug,
41 impl<St, Fut, F> SkipWhile<St, Fut, F>
44 F: FnMut(&St::Item) -> Fut,
45 Fut: Future<Output = bool>,
54 impl<St, Fut, F> FusedStream for SkipWhile<St, Fut, F>
57 F: FnMut(&St::Item) -> Fut,
58 Fut: Future<Output = bool>,
[all …]
Dfilter.rs15 pub struct Filter<St, Fut, F>
22 pending_fut: Option<Fut>,
27 impl<St, Fut, F> fmt::Debug for Filter<St, Fut, F>
31 Fut: fmt::Debug,
43 impl<St, Fut, F> Filter<St, Fut, F>
46 F: for<'a> FnMut1<&'a St::Item, Output = Fut>,
47 Fut: Future<Output = bool>,
56 impl<St, Fut, F> FusedStream for Filter<St, Fut, F>
59 F: FnMut(&St::Item) -> Fut,
60 Fut: Future<Output = bool>,
[all …]
Dscan.rs19 pub struct Scan<St: Stream, S, Fut, F> {
24 future: Option<Fut>,
28 impl<St, S, Fut, F> fmt::Debug for Scan<St, S, Fut, F>
33 Fut: fmt::Debug,
45 impl<St: Stream, S, Fut, F> Scan<St, S, Fut, F> {
52 impl<B, St, S, Fut, F> Scan<St, S, Fut, F>
55 F: FnMut(&mut S, St::Item) -> Fut,
56 Fut: Future<Output = Option<B>>,
65 impl<B, St, S, Fut, F> Stream for Scan<St, S, Fut, F>
68 F: FnMut(&mut S, St::Item) -> Fut,
[all …]
/external/rust/crates/futures-util/src/sink/
Dwith.rs14 pub struct With<Si, Item, U, Fut, F> {
19 state: Option<Fut>,
24 impl<Si, Item, U, Fut, F> fmt::Debug for With<Si, Item, U, Fut, F>
27 Fut: fmt::Debug,
34 impl<Si, Item, U, Fut, F> With<Si, Item, U, Fut, F>
37 F: FnMut(U) -> Fut,
38 Fut: Future,
42 Fut: Future<Output = Result<Item, E>>, in new()
49 impl<Si, Item, U, Fut, F> Clone for With<Si, Item, U, Fut, F>
53 Fut: Clone,
[all …]
/external/rust/crates/futures-util/src/stream/try_stream/
Dand_then.rs14 pub struct AndThen<St, Fut, F> {
18 future: Option<Fut>,
23 impl<St, Fut, F> fmt::Debug for AndThen<St, Fut, F>
26 Fut: fmt::Debug,
36 impl<St, Fut, F> AndThen<St, Fut, F>
39 F: FnMut(St::Ok) -> Fut,
40 Fut: TryFuture<Error = St::Error>,
49 impl<St, Fut, F> Stream for AndThen<St, Fut, F>
52 F: FnMut(St::Ok) -> Fut,
53 Fut: TryFuture<Error = St::Error>,
[all …]
Dor_else.rs14 pub struct OrElse<St, Fut, F> {
18 future: Option<Fut>,
23 impl<St, Fut, F> fmt::Debug for OrElse<St, Fut, F>
26 Fut: fmt::Debug,
36 impl<St, Fut, F> OrElse<St, Fut, F>
39 F: FnMut(St::Error) -> Fut,
40 Fut: TryFuture<Ok = St::Ok>,
49 impl<St, Fut, F> Stream for OrElse<St, Fut, F>
52 F: FnMut(St::Error) -> Fut,
53 Fut: TryFuture<Ok = St::Ok>,
[all …]
/external/rust/crates/futures-util/src/stream/
Dfutures_ordered.rs104 impl<Fut: Future> FuturesOrdered<Fut> {
139 pub fn push(&mut self, future: Fut) { in push() argument
149 pub fn push_back(&mut self, future: Fut) { in push_back() argument
162 pub fn push_front(&mut self, future: Fut) { in push_front() argument
169 impl<Fut: Future> Default for FuturesOrdered<Fut> {
175 impl<Fut: Future> Stream for FuturesOrdered<Fut> {
176 type Item = Fut::Output;
210 impl<Fut: Future> Debug for FuturesOrdered<Fut> {
216 impl<Fut: Future> FromIterator<Fut> for FuturesOrdered<Fut> {
219 T: IntoIterator<Item = Fut>, in from_iter()
[all …]
Donce.rs20 pub fn once<Fut: Future>(future: Fut) -> Once<Fut> { in once() argument
21 assert_stream::<Fut::Output, _>(Once::new(future)) in once()
28 pub struct Once<Fut> {
30 future: Option<Fut>
34 impl<Fut> Once<Fut> {
35 pub(crate) fn new(future: Fut) -> Self { in new()
40 impl<Fut: Future> Stream for Once<Fut> {
41 type Item = Fut::Output;
63 impl<Fut: Future> FusedStream for Once<Fut> {

12345