| /external/rust/crates/futures/tests/ |
| D | futures_unordered.rs | 2 use futures::stream::{FuturesUnordered, StreamExt};
11 use futures::stream::{FusedStream, FuturesUnordered, StreamExt}; in is_terminated()
16 let mut tasks = FuturesUnordered::new(); in is_terminated()
44 use futures::stream::FuturesUnordered; in works_1()
53 .collect::<FuturesUnordered<_>>(), in works_1()
70 use futures::stream::{FuturesUnordered, StreamExt}; in works_2()
83 .collect::<FuturesUnordered<_>>(); in works_2()
99 use futures::stream::{FuturesUnordered, StreamExt}; in from_iterator()
107 .collect::<FuturesUnordered<_>>(); in from_iterator()
117 use futures::stream::{FuturesUnordered, StreamExt}; in finished_future()
[all …]
|
| D | ready_queue.rs | 2 use futures::stream::FuturesUnordered;
5 impl AssertSendSync for FuturesUnordered<()> {} implementation
13 use futures::stream::{FuturesUnordered, StreamExt}; in basic_usage()
17 let mut queue = FuturesUnordered::new(); in basic_usage()
47 use futures::stream::{FuturesUnordered, StreamExt}; in resolving_errors()
51 let mut queue = FuturesUnordered::new(); in resolving_errors()
81 use futures::stream::FuturesUnordered; in dropping_ready_queue()
85 let queue = FuturesUnordered::new(); in dropping_ready_queue()
113 use futures::stream::FuturesUnordered; in stress()
122 let mut queue = FuturesUnordered::new(); in stress()
[all …]
|
| D | stream_select_next_some.rs | 5 use futures::stream::{FuturesUnordered, StreamExt}; in is_terminated()
12 let mut tasks = FuturesUnordered::new(); in is_terminated()
34 use futures::stream::{FuturesUnordered, StreamExt}; in select()
43 let mut async_tasks = FuturesUnordered::new(); in select()
65 use futures::stream::{FuturesUnordered, StreamExt}; in futures_util_select()
76 let mut async_tasks = FuturesUnordered::new(); in futures_util_select()
|
| D | auto_traits.rs | 1298 assert_impl!(FuturesUnordered<()>: Send);
1299 assert_not_impl!(FuturesUnordered<*const ()>: Send);
1300 assert_impl!(FuturesUnordered<()>: Sync);
1301 assert_not_impl!(FuturesUnordered<*const ()>: Sync);
1302 assert_impl!(FuturesUnordered<PhantomPinned>: Unpin);
|
| /external/rust/crates/futures-util/src/stream/futures_unordered/ |
| D | mod.rs | 55 pub struct FuturesUnordered<Fut> { struct
61 unsafe impl<Fut: Send> Send for FuturesUnordered<Fut> {} argument
62 unsafe impl<Fut: Sync> Sync for FuturesUnordered<Fut> {} implementation
63 impl<Fut> Unpin for FuturesUnordered<Fut> {} implementation
65 impl Spawn for FuturesUnordered<FutureObj<'_, ()>> { implementation
74 impl LocalSpawn for FuturesUnordered<LocalFutureObj<'_, ()>> { implementation
108 impl<Fut> Default for FuturesUnordered<Fut> { implementation
114 impl<Fut> FuturesUnordered<Fut> { implementation
395 impl<Fut: Future> Stream for FuturesUnordered<Fut> { implementation
507 queue: &'a mut FuturesUnordered<Fut>, in poll_next()
[all …]
|
| D | iter.rs | 1 use super::FuturesUnordered;
12 pub(super) _marker: PhantomData<&'a mut FuturesUnordered<Fut>>
25 pub(super) _marker: PhantomData<&'a FuturesUnordered<Fut>>
|
| /external/rust/crates/futures-util/src/stream/try_stream/ |
| D | try_for_each_concurrent.rs | 1 use crate::stream::{FuturesUnordered, StreamExt};
20 futures: FuturesUnordered<Fut>,
60 futures: FuturesUnordered::new(), in new()
98 drop(mem::replace(this.futures, FuturesUnordered::new())); in poll()
120 drop(mem::replace(this.futures, FuturesUnordered::new())); in poll()
|
| D | try_buffer_unordered.rs | 1 use crate::stream::{Fuse, FuturesUnordered, StreamExt, IntoStream};
21 in_progress_queue: FuturesUnordered<IntoFuture<St::Ok>>,
33 in_progress_queue: FuturesUnordered::new(), in new()
|
| /external/rust/crates/futures-util/src/stream/ |
| D | select_all.rs | 12 use crate::stream::{StreamExt, StreamFuture, FuturesUnordered};
28 inner: FuturesUnordered<StreamFuture<St>>,
43 Self { inner: FuturesUnordered::new() } in new()
|
| D | futures_ordered.rs | 1 use crate::stream::{FuturesUnordered, StreamExt};
99 in_progress_queue: FuturesUnordered<OrderWrapper<T>>,
114 in_progress_queue: FuturesUnordered::new(), in new()
|
| D | mod.rs | 104 pub use self::futures_unordered::FuturesUnordered;
|
| /external/rust/crates/futures-util/src/stream/stream/ |
| D | buffer_unordered.rs | 1 use crate::stream::{Fuse, FuturesUnordered, StreamExt};
21 in_progress_queue: FuturesUnordered<St::Item>,
51 in_progress_queue: FuturesUnordered::new(), in new()
|
| D | for_each_concurrent.rs | 1 use crate::stream::{FuturesUnordered, StreamExt};
18 futures: FuturesUnordered<Fut>,
48 futures: FuturesUnordered::new(), in new()
|
| /external/rust/crates/futures-util/benches/ |
| D | futures_unordered.rs | 9 use futures::stream::{StreamExt, FuturesUnordered};
20 let mut rxs = FuturesUnordered::new(); in oneshots()
|
| /external/rust/crates/futures-executor/src/ |
| D | local_pool.rs | 8 use futures_util::stream::FuturesUnordered;
29 pool: FuturesUnordered<LocalFutureObj<'static, ()>>,
123 pool: FuturesUnordered::new(), in new()
|
| /external/crosvm/devices/src/virtio/ |
| D | block_async.rs | 17 use futures::stream::{FuturesUnordered, StreamExt};
525 .collect::<FuturesUnordered<_>>() in run_worker()
|