Trait stream_throttle::ThrottledStream

pub trait ThrottledStream {
    fn throttle(self, pool: ThrottlePool) -> Throttled<Self>
    where
        Self: Stream + Sized,
    { ... }
}

Provides a throttle() method on all Stream’s.

Provided methods

fn throttle(self, pool: ThrottlePool) -> Throttled<Self> where
    Self: Stream + Sized, 

Returns a new stream, which throttles items from the original stream, according to the rate defined by pool.

Loading content...

Implementors

impl<T: Stream> ThrottledStream for T

Loading content...