Trait StreamExt 

pub trait StreamExt<'a, F>: Stream {
    // Provided methods
    fn progress(
        self,
        progress: ProgressStyle<'a>,
        progress_fn: F,
    ) -> Progress<'a, Self, F, impl Stream<Item = char> + use<'a, F, Self>, impl Stream<Item = impl Display>>
       where Self: Sized,
             F: FnMut(usize, &Self::Item) -> f64 + Unpin { ... }
    fn progress_with_messages(
        self,
        progress: ProgressStyle<'a>,
        progress_fn: F,
        messages: impl Stream<Item = impl Display>,
    ) -> Progress<'a, Self, F, impl Stream<Item = char>, impl Stream<Item = impl Display>>
       where Self: Sized,
             F: FnMut(usize, &Self::Item) -> f64 + Unpin { ... }
}

Provided Methods

fn progress( self, progress: ProgressStyle<'a>, progress_fn: F, ) -> Progress<'a, Self, F, impl Stream<Item = char> + use<'a, F, Self>, impl Stream<Item = impl Display>>

where Self: Sized, F: FnMut(usize, &Self::Item) -> f64 + Unpin,

fn progress_with_messages( self, progress: ProgressStyle<'a>, progress_fn: F, messages: impl Stream<Item = impl Display>, ) -> Progress<'a, Self, F, impl Stream<Item = char>, impl Stream<Item = impl Display>>

where Self: Sized, F: FnMut(usize, &Self::Item) -> f64 + Unpin,

Implementors

impl<'a, S, F> StreamExt<'a, F> for S

where S: Stream,