Searched refs:BlockingStream (Results 1 – 3 of 3) sorted by relevance
324 pub fn block_on_stream<S: Stream + Unpin>(stream: S) -> BlockingStream<S> { in block_on_stream()325 BlockingStream { stream } in block_on_stream()330 pub struct BlockingStream<S: Stream + Unpin> { struct334 impl<S: Stream + Unpin> Deref for BlockingStream<S> { argument341 impl<S: Stream + Unpin> DerefMut for BlockingStream<S> { implementation347 impl<S: Stream + Unpin> BlockingStream<S> { implementation354 impl<S: Stream + Unpin> Iterator for BlockingStream<S> { implementation
52 pub use crate::local_pool::{block_on, block_on_stream, BlockingStream, LocalPool, LocalSpawner};
184 assert_impl!(BlockingStream<SendStream>: Send);185 assert_not_impl!(BlockingStream<LocalStream>: Send);186 assert_impl!(BlockingStream<SyncStream>: Sync);187 assert_not_impl!(BlockingStream<LocalStream>: Sync);188 assert_impl!(BlockingStream<UnpinStream>: Unpin);