pub fn block_on_stream<S>(s: S) -> BlockingStream<S> ⓘwhere
S: Stream,
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.
The default executor for the future is a global ThreadPool
.