Struct async_speed_limit::limiter::Consume

pub struct Consume<C: Clock, R> { /* private fields */ }

The future returned by Limiter::consume().

Implementations

impl<C: Clock, R> Consume<C, R>

pub fn map<T, F: FnOnce(R) -> T>(self, f: F) -> Consume<C, T>

Replaces the return value of the future.

Trait Implementations

impl<C: Debug + Clock, R: Debug> Debug for Consume<C, R>where C::Delay: Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<C: Clock, R: Unpin> FusedFuture for Consume<C, R>

fn is_terminated(&self) -> bool

Returns true if the underlying future should no longer be polled.

impl<C: Clock, R: Unpin> Future for Consume<C, R>

type Output = R

The type of value produced on completion.

fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output>

Attempt to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.