fn timed<C, R>(self, callback: C) -> BoxStream<Self::Item, Self::Error>
    where
        C: FnOnce(StreamStats, Result<(), &Self::Error>) -> R + Send + 'static,
        R: IntoFuture<Item = (), Error = ()> + Send + 'static,
        R::Future: 'static,
        <R as futures_old::IntoFuture>::Future: Send,
        Self::Item: Send,
        Self::Error: Send,
    {
        TimedStream::new(self, callback).boxify()
    }
/// Combinator that returns a stream that will gather some statistics using
/// [TimedStream] and pass them for inspection to the provided callback.
Combinator that returns a stream that will gather some statistics using
[TimedStream] and pass them for inspection to the provided callback.
Combinator that returns a stream that will gather some statistics using [ TimedStream ] and pass them for inspection to the provided callback .
fn timed<C, R>(self, callback: C) -> BoxStream<Self::Item, Self::Error>
    where
        C: FnOnce(StreamStats, Result<(), &Self::Error>) -> R + Send + 'static,
        R: IntoFuture<Item = (), Error = ()> + Send + 'static,
        R::Future: 'static,
        <R as futures_old::IntoFuture>::Future: Send,
        Self::Item: Send,
        Self::Error: Send,
    {
        TimedStream::new(self, callback).boxify()
    }
fn timed < C , R > ( self , callback : C ) -> BoxStream < Self :: Item , Self :: Error > where C : FnOnce ( StreamStats , Result < ( ) , & Self :: Error > ) -> R + Send + ' static , R : IntoFuture < Item = ( ) , Error = ( ) > + Send + ' static , R :: Future : ' static , < R as futures_old :: IntoFuture > :: Future : Send , Self :: Item : Send , Self :: Error : Send , { TimedStream :: new ( self , callback ) . boxify ( ) }
Combinator that returns a stream that will gather some statistics using
[TimedStream] and pass them for inspection to the provided callback.
Combinator that returns a stream that will gather some statistics using [ TimedStream ] and pass them for inspection to the provided callback .
self
callback
C
self
callback
C