use leaky_bucket::RateLimiter;
use tokio::time::Instant;

#[tokio::main]
async fn main() {
    helpers::init_logging();

    let limiter = RateLimiter::builder().max(10).initial(0).refill(5).build();

    let start = Instant::now();

    println!("Waiting for permit...");

    // Should take ~400 ms to acquire in total.
    let a = limiter.acquire(7);
    let b = limiter.acquire(3);
    let c = limiter.acquire(10);

    let ((), (), ()) = tokio::join!(a, b, c);

    println!("I made it in {:?}!", Instant::now().duration_since(start));
}