tokio-based leaky-bucket rate limiter
This project is a rate limiter based on the leaky bucket algorithm.
Usage
This library requires the user to add the following dependencies to use:
leaky-bucket = "0.1.0"
Examples
#![feature(async_await)]
use futures::prelude::*;
use leaky_bucket::LeakyBucket;
use std::{error::Error, time::Duration};
#[tokio::main]
async fn main() -> Result<(), Box<dyn Error>> {
let rate_limiter = LeakyBucket::builder()
.max(100)
.refill_interval(Duration::from_secs(10))
.refill_amount(100)
.build();
let coordinator = rate_limiter.coordinate().boxed();
tokio::spawn(async move { coordinator.await.expect("coordinate thread errored") });
println!("Waiting for permit...");
rate_limiter.acquire(100).await;
println!("I made it!");
Ok(())
}