Function futures_executor::block_on_stream[−][src]

pub fn block_on_stream<S: Stream + Unpin>(stream: S) -> BlockingStream<S>ⓘ
Notable traits for BlockingStream<S>
impl<S: Stream + Unpin> Iterator for BlockingStream<S>    type Item = S::Item;

Turn a stream into a blocking iterator.

When next is called on the resulting BlockingStream, the caller will be blocked until the next element of the Stream becomes available.