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 async_indicator<P>(self, op: P) -> Operated<Self, P>
fn async_indicator<P>(self, op: P) -> Operated<Self, P>
Apply an AsyncOperator
on the stream.