Function futures::executor::block_on_stream [−] [src]

Important traits for BlockingStream<S>

impl<S> Iterator for BlockingStream<S> where
    S: Stream,     type Item = Result<<S as Stream>::Item, <S as Stream>::Error>;

pub fn block_on_stream<S>(s: S) -> BlockingStream<S> where
    S: Stream,

Turn a stream into a blocking iterator.

Whne next is called on the resulting BlockingStream, the caller will be blocked until the next element of the Stream becomes available. The default executor for the future is a global ThreadPool.