Function futures::executor::block_on_stream

Important traits for BlockingStream<S>

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

pub fn block_on_stream<S>(stream: S) -> BlockingStream<S> where
    S: Unpin + Stream, 

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. The default spawner for the future is a global ThreadPool.