A token-based rate limiter based on the [leaky bucket] algorithm, mainly a lazy reimplementation of [udoprog's leaky-bucket] with less dependencies and overhead.
If the tokens are already available, the acquisition will be instant through a fast path, and the acquired number of tokens will be added to the bucket.
If they aren't, the task that tried to acquire the tokens will be suspended until the required number of tokens has been added.
Add the following to your Cargo.toml:
toml
leaky-bucket-lite = "0.4"
leaky-bucket-lite provides 3 implementations:
* [LeakyBucket] (thread-safe, available via the tokio feature, which is on by default)
* [sync_threadsafe::LeakyBucket] (thread-safe, available via the sync-threadsafe feature)
* [sync::LeakyBucket] (not thread-safe, available via the sync feature).
For potential performance increase with sync-threadsafe or tokio using [parking_lot]'s locking objects, enable the parking_lot feature.
```rust use leakybucketlite::LeakyBucket; use std::time::Duration;
async fn main() { let ratelimiter = LeakyBucket::builder() .max(5) .tokens(0) .refillinterval(Duration::fromsecs(1)) .refillamount(1) .build();
println!("Waiting for permit...");
// should take about 5 seconds to acquire.
rate_limiter.acquire(5).await;
println!("I made it!");
} ```