Function futures_executor::block_on_stream
source · [−]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;
Expand description
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.