Function hydroflow::util::collect_ready

source · 
pub fn collect_ready<C, S>(stream: S) -> C
where
    C: FromIterator<S::Item>,
    S: Stream,
Expand description

Collects the immediately available items from the Stream into a FromIterator collection.

This consumes the stream, use futures::StreamExt::by_ref() (or just &mut ...) if you want to retain ownership of your stream.