Struct RateLimit 

pub struct RateLimit<T> { /* private fields */ }

Async rate limit implementation

use std::time::Duration;
use rate_limit_wrapper::RateLimit;

#[tokio::main]
async fn main() {
  // 10 requests per second
  let rm = RateLimit::new(10, Duration::from_secs(1), reqwest::Client::new());

  // Access inner client bypassing rate limit
  let request = rm.as_ref().get("https://www.rust-lang.org").build().unwrap();

  // Apply rate limit
  let client = rm.rate_limit(1).await;
  client.execute(request).await.unwrap();
}

Implementations

impl<T> RateLimit<T>

pub fn new(size: usize, window: Duration, inner: T) -> Self

pub fn rate_limit(&self, weight: usize) -> RateLimitFuture<'_, T>

Trait Implementations

impl<T> AsRef<T> for RateLimit<T>

fn as_ref(&self) -> &T

Converts this type into a shared reference of the (usually inferred) input type.