Trait indicator::stream::IndicatorStreamExt

pub trait IndicatorStreamExt: Stream {
    fn indicator<P>(self, op: P) -> Operated<Self, P>
    where
        Self: Sized,
        P: Operator<Self::Item>,
    { ... }
    fn async_indicator<P>(self, op: P) -> Operated<Self, P>
    where
        Self: Sized,
        P: AsyncOperator<Self::Item>,
    { ... }
}

Stream extension trait for indicators.

Provided Methods

fn indicator<P>(self, op: P) -> Operated<Self, P>where
    Self: Sized,
    P: Operator<Self::Item>,

Apply an Operator on the stream.

fn async_indicator<P>(self, op: P) -> Operated<Self, P>where
    Self: Sized,
    P: AsyncOperator<Self::Item>,

Apply an AsyncOperator on the stream.

Implementors

impl<St: Stream> IndicatorStreamExt for St