Trait indicator::stream::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§
sourcefn indicator<P>(self, op: P) -> Operated<Self, P>where
Self: Sized,
P: Operator<Self::Item>,
fn indicator<P>(self, op: P) -> Operated<Self, P>where Self: Sized, P: Operator<Self::Item>,
Apply an Operator on the stream.
sourcefn async_indicator<P>(self, op: P) -> Operated<Self, P>where
Self: Sized,
P: AsyncOperator<Self::Item>,
fn async_indicator<P>(self, op: P) -> Operated<Self, P>where Self: Sized, P: AsyncOperator<Self::Item>,
Apply an AsyncOperator on the stream.