Struct TokenBucket 

pub struct TokenBucket { /* private fields */ }

A token bucket: at most burst requests at once, refilled at per_second. A caller that finds it empty waits for its token, which is booked as it starts waiting, so callers are served in turn and a dropped wait still spends its token.

Implementations

impl TokenBucket

pub fn new(per_second: u32, burst: u32) -> Self

A bucket of burst tokens (at least one), refilled at per_second; 0 means no limit.

pub async fn take(&self)

Take a token, waiting for one when the bucket is empty.

Trait Implementations

impl Debug for TokenBucket

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

Formats the value using the given formatter.