Struct stream_throttle::ThrottlePool [−][src]
A clonable object which is used to throttle one or more streams, according to a shared rate.
Implementations
impl ThrottlePool[src]
pub fn new(rate: ThrottleRate) -> Self[src]
pub fn queue(&self) -> impl Future<Output = ()>[src]
Produces a future which will resolve once the pool has an available slot.
Each Throttled stream will call this method during polling, once for each item the
underlying stream produces. These futures are driven to completion by polling the
Throttled stream. In the process, these futures will drive the ThrottlePool,
freeing up slots.
Trait Implementations
impl Clone for ThrottlePool[src]
fn clone(&self) -> ThrottlePool[src]
pub fn clone_from(&mut self, source: &Self)1.0.0[src]
Auto Trait Implementations
impl RefUnwindSafe for ThrottlePool
impl Send for ThrottlePool
impl Sync for ThrottlePool
impl Unpin for ThrottlePool
impl UnwindSafe for ThrottlePool
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized, [src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized, [src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized, [src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T[src]
impl<T> From<T> for T[src]
impl<T, U> Into<U> for T where
U: From<T>, [src]
U: From<T>,
impl<T> ToOwned for T where
T: Clone, [src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
pub fn to_owned(&self) -> T[src]
pub fn clone_into(&self, target: &mut T)[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>, [src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>, [src]
U: TryFrom<T>,