Home
last modified time | relevance | path

Searched refs:FuturesOrdered (Results 1 – 6 of 6) sorted by relevance

/external/rust/crates/futures-util/src/stream/
Dfutures_ordered.rs98 pub struct FuturesOrdered<T: Future> { struct
105 impl<T: Future> Unpin for FuturesOrdered<T> {} argument
107 impl<Fut: Future> FuturesOrdered<Fut> { implementation
151 impl<Fut: Future> Default for FuturesOrdered<Fut> { implementation
157 impl<Fut: Future> Stream for FuturesOrdered<Fut> { implementation
192 impl<Fut: Future> Debug for FuturesOrdered<Fut> { implementation
198 impl<Fut: Future> FromIterator<Fut> for FuturesOrdered<Fut> { implementation
211 impl<Fut: Future> FusedStream for FuturesOrdered<Fut> { implementation
217 impl<Fut: Future> Extend<Fut> for FuturesOrdered<Fut> { implementation
Dmod.rs98 pub use self::futures_ordered::FuturesOrdered;
/external/rust/crates/futures/tests/
Dfutures_ordered.rs5 use futures::stream::{StreamExt, FuturesOrdered}; in works_1()
12 let mut stream = vec![a_rx, b_rx, c_rx].into_iter().collect::<FuturesOrdered<_>>(); in works_1()
31 use futures::stream::{StreamExt, FuturesOrdered}; in works_2()
41 ].into_iter().collect::<FuturesOrdered<_>>(); in works_2()
56 use futures::stream::{StreamExt, FuturesOrdered}; in from_iterator()
62 ].into_iter().collect::<FuturesOrdered<_>>(); in from_iterator()
71 use futures::stream::{StreamExt, FuturesOrdered}; in queue_never_unblocked()
84 ].into_iter().collect::<FuturesOrdered<_>>(); in queue_never_unblocked()
Dauto_traits.rs1290 assert_impl!(FuturesOrdered<SendFuture<()>>: Send);
1291 assert_not_impl!(FuturesOrdered<SendFuture>: Send);
1292 assert_not_impl!(FuturesOrdered<SendFuture>: Send);
1293 assert_impl!(FuturesOrdered<SyncFuture<()>>: Sync);
1294 assert_not_impl!(FuturesOrdered<LocalFuture<()>>: Sync);
1295 assert_not_impl!(FuturesOrdered<LocalFuture<()>>: Sync);
1296 assert_impl!(FuturesOrdered<PinnedFuture>: Unpin);
/external/rust/crates/futures-util/src/stream/try_stream/
Dtry_buffered.rs1 use crate::stream::{Fuse, FuturesOrdered, StreamExt, IntoStream};
22 in_progress_queue: FuturesOrdered<IntoFuture<St::Ok>>,
35 in_progress_queue: FuturesOrdered::new(), in new()
/external/rust/crates/futures-util/src/stream/stream/
Dbuffered.rs1 use crate::stream::{Fuse, FuturesOrdered, StreamExt};
22 in_progress_queue: FuturesOrdered<St::Item>,
49 in_progress_queue: FuturesOrdered::new(), in new()