1 use futures::future::Future;
2 use futures::stream::{FuturesUnordered, StreamExt};
3 use futures::task::{Context, Poll};
10     use futures::future;  in is_terminated()
11     use futures::stream::{FusedStream, FuturesUnordered, StreamExt};  in is_terminated()
12     use futures::task::Poll;  in is_terminated()
42     use futures::channel::oneshot;  in works_1()
43     use futures::executor::block_on_stream;  in works_1()
44     use futures::stream::FuturesUnordered;  in works_1()
68     use futures::channel::oneshot;  in works_2()
69     use futures::future::{join, FutureExt};  in works_2()
70     use futures::stream::{FuturesUnordered, StreamExt};  in works_2()
71     use futures::task::Poll;  in works_2()
97     use futures::executor::block_on;  in from_iterator()
98     use futures::future;  in from_iterator()
99     use futures::stream::{FuturesUnordered, StreamExt};  in from_iterator()
115     use futures::channel::oneshot;  in finished_future()
116     use futures::future::{self, Future, FutureExt};  in finished_future()
117     use futures::stream::{FuturesUnordered, StreamExt};  in finished_future()
145     use futures::channel::oneshot;  in iter_mut_cancel()
146     use futures::executor::block_on_stream;  in iter_mut_cancel()
147     use futures::stream::FuturesUnordered;  in iter_mut_cancel()
167     assert_eq!(iter.next(), Some(Err(futures::channel::oneshot::Canceled)));  in iter_mut_cancel()
168     assert_eq!(iter.next(), Some(Err(futures::channel::oneshot::Canceled)));  in iter_mut_cancel()
169     assert_eq!(iter.next(), Some(Err(futures::channel::oneshot::Canceled)));  in iter_mut_cancel()
175     use futures::future;  in iter_mut_len()
176     use futures::stream::FuturesUnordered;  in iter_mut_len()
203     use futures::executor::block_on_stream;  in iter_cancel()
204     use futures::future::{self, Future, FutureExt};  in iter_cancel()
205     use futures::stream::FuturesUnordered;  in iter_cancel()
206     use futures::task::{Context, Poll};  in iter_cancel()
253     use futures::future;  in iter_len()
254     use futures::stream::FuturesUnordered;  in iter_len()
277     use futures::future;  in futures_not_moved_after_poll()
278     use futures::stream::FuturesUnordered;  in futures_not_moved_after_poll()
295     use futures::channel::oneshot;  in len_valid_during_out_of_order_completion()
296     use futures::stream::{FuturesUnordered, StreamExt};  in len_valid_during_out_of_order_completion()
297     use futures::task::Poll;  in len_valid_during_out_of_order_completion()