Trait async_utils::stream::TryFlattenUnorderedExt

pub trait TryFlattenUnorderedExt: TryStream + Sized {
    // Required method
    fn try_flatten_unordered(self) -> TryFlattenUnordered<Self>;
}

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

Required Methods

fn try_flatten_unordered(self) -> TryFlattenUnordered<Self>

Creates a TryFlattenUnordered stream from a stream of streams.

Implementors

impl<S> TryFlattenUnorderedExt for Swhere S: TryStream + FusedStream + Sized, S::Ok: TryStream<Error = S::Error> + Unpin,