Function dfir_rs::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.