indicator::stream

Trait IndicatorStreamExt

Source 
pub trait IndicatorStreamExt: Stream {
    // Provided methods
    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> { ... }
}
Expand description

Stream extension trait for indicators.

Provided Methods§

Source

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

Apply an Operator on the stream.

Source

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

Apply an AsyncOperator on the stream.

Implementors§