| /external/rust/crates/tokio-stream/tests/ |
| D | async_send_sync.rs | 100 async_assert_fn!(tokio_stream::StreamExt::next(&mut BoxStream<()>): !Unpin);
101 async_assert_fn!(tokio_stream::StreamExt::try_next(&mut BoxStream<Result<(), ()>>): !Unpin);
102 async_assert_fn!(tokio_stream::StreamExt::all(&mut BoxStream<()>, fn(())->bool): !Unpin);
103 async_assert_fn!(tokio_stream::StreamExt::any(&mut BoxStream<()>, fn(())->bool): !Unpin);
104 async_assert_fn!(tokio_stream::StreamExt::fold(&mut BoxStream<()>, (), fn((), ())->()): !Unpin);
105 async_assert_fn!(tokio_stream::StreamExt::collect<Vec<()>>(&mut BoxStream<()>): !Unpin);
|
| D | stream_timeout.rs | 4 use tokio_stream::{self, StreamExt};
7 use futures::StreamExt as _;
|
| D | stream_empty.rs | 1 use tokio_stream::{self as stream, Stream, StreamExt};
|
| D | stream_pending.rs | 1 use tokio_stream::{self as stream, Stream, StreamExt};
|
| D | stream_once.rs | 1 use tokio_stream::{self as stream, Stream, StreamExt};
|
| D | time_throttle.rs | 5 use tokio_stream::StreamExt;
|
| /external/rust/crates/futures/tests/ |
| D | stream.rs | 4 use futures::stream::{self, StreamExt}; in select()
20 use futures::stream::{self, StreamExt}; in flat_map()
40 use futures::stream::{self, StreamExt}; in scan()
59 use futures::stream::{self, StreamExt}; in take_until()
128 use futures::stream::StreamExt; in ready_chunks_panic_on_cap_zero()
138 use futures::stream::StreamExt; in ready_chunks()
|
| D | stream_select_next_some.rs | 5 use futures::stream::{FuturesUnordered, StreamExt}; in is_terminated()
34 use futures::stream::{FuturesUnordered, StreamExt}; in select()
65 use futures::stream::{FuturesUnordered, StreamExt}; in futures_util_select()
|
| D | futures_ordered.rs | 5 use futures::stream::{StreamExt, FuturesOrdered}; in works_1()
31 use futures::stream::{StreamExt, FuturesOrdered}; in works_2()
56 use futures::stream::{StreamExt, FuturesOrdered}; in from_iterator()
71 use futures::stream::{StreamExt, FuturesOrdered}; in queue_never_unblocked()
|
| D | stream_catch_unwind.rs | 4 use futures::stream::{self, StreamExt}; in panic_in_the_middle_of_the_stream()
20 use futures::stream::{self, StreamExt}; in no_panic()
|
| D | futures_unordered.rs | 2 use futures::stream::{FuturesUnordered, StreamExt};
11 use futures::stream::{FusedStream, FuturesUnordered, StreamExt}; in is_terminated()
70 use futures::stream::{FuturesUnordered, StreamExt}; in works_2()
99 use futures::stream::{FuturesUnordered, StreamExt}; in from_iterator()
117 use futures::stream::{FuturesUnordered, StreamExt}; in finished_future()
296 use futures::stream::{FuturesUnordered, StreamExt}; in len_valid_during_out_of_order_completion()
|
| D | io_lines.rs | 21 use futures::stream::StreamExt; in lines()
44 use futures::stream::{self, StreamExt, TryStreamExt}; in maybe_pending()
|
| D | ready_queue.rs | 13 use futures::stream::{FuturesUnordered, StreamExt}; in basic_usage()
47 use futures::stream::{FuturesUnordered, StreamExt}; in resolving_errors()
162 use futures::stream::{FuturesUnordered, StreamExt}; in panicking_future_dropped()
|
| D | stream_peekable.rs | 5 use futures::stream::{self, Peekable, StreamExt}; in peekable()
|
| D | sink_fanout.rs | 7 use futures::stream::{self, StreamExt}; in it_works()
|
| D | sink.rs | 2 use futures::stream::{Stream, StreamExt};
306 use futures::stream::{self, StreamExt}; in send_all()
410 use futures::stream::{self, StreamExt}; in with_flat_map()
492 use futures::{SinkExt, StreamExt}; in with_implements_clone()
572 use futures::stream::{self, StreamExt}; in fanout_smoke()
589 use futures::stream::StreamExt; in fanout_backpressure()
|
| /external/rust/crates/futures/src/ |
| D | lib.rs | 111 pub use futures_util::stream::{StreamExt, TryStreamExt};
182 pub use crate::stream::{StreamExt as _, TryStreamExt as _};
|
| /external/rust/crates/async-stream/tests/ |
| D | for_await.rs | 3 use futures_util::stream::StreamExt;
|
| /external/rust/crates/async-stream/examples/ |
| D | tcp_accept.rs | 3 use futures_util::stream::StreamExt;
|
| /external/rust/crates/tokio/tests/ |
| D | task_blocking.rs | 183 use tokio_stream::StreamExt; in coop_disabled_in_block_in_place()
213 use tokio_stream::StreamExt; in coop_disabled_in_block_in_place_in_block_on()
|
| /external/rust/crates/tokio-stream/src/ |
| D | stream_ext.rs | 92 pub trait StreamExt: Stream { interface
904 impl<St: ?Sized> StreamExt for St where St: Stream {}
|
| D | lib.rs | 80 pub use stream_ext::{collect::FromStream, StreamExt};
|
| /external/rust/crates/async-stream/ |
| D | README.md | 25 use futures_util::stream::StreamExt;
50 use futures_util::stream::StreamExt;
78 use futures_util::stream::StreamExt;
|
| /external/rust/crates/futures-util/benches/ |
| D | futures_unordered.rs | 9 use futures::stream::{StreamExt, FuturesUnordered};
|
| /external/rust/crates/futures-util/src/stream/stream/ |
| D | next.rs | 1 use crate::stream::StreamExt;
|