Searched refs:BoxStream (Results 1 – 4 of 4) sorted by relevance
| /external/rust/crates/tokio-stream/tests/ |
| D | async_send_sync.rs | 4 type BoxStream<T> = std::pin::Pin<Box<dyn tokio_stream::Stream<Item = T>>>; typedef
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);
|
| /external/rust/crates/futures-util/src/stream/ |
| D | mod.rs | 13 pub use futures_core::stream::{BoxStream, LocalBoxStream};
|
| /external/rust/crates/futures-core/src/ |
| D | stream.rs | 10 pub type BoxStream<'a, T> = Pin<alloc::boxed::Box<dyn Stream<Item = T> + Send + 'a>>; typedef
|
| /external/rust/crates/futures-util/src/stream/stream/ |
| D | mod.rs | 16 use futures_core::stream::{BoxStream, LocalBoxStream};
1112 fn boxed<'a>(self) -> BoxStream<'a, Self::Item> in boxed()
|