Trait async_utils::stream::FlattenUnorderedExt

pub trait FlattenUnorderedExt: Stream + Sized {
    // Required method
    fn flatten_unordered(self) -> FlattenUnordered<Self>;
}

Extension trait to allow for easy creation of a FlattenUnordered stream from a Stream.

Required Methods

fn flatten_unordered(self) -> FlattenUnordered<Self>

Creates a FlattenUnordered stream from a stream of streams.

Implementors

impl<S> FlattenUnorderedExt for Swhere S: Stream + FusedStream + Sized, S::Item: Stream + Unpin,