Struct ratelimit::Handle

source ·

pub struct Handle { /* private fields */ }

Expand description

Handler for a multi-threaded rate-limiter.

Implementations

source

impl Handle

source

pub fn wait(&mut self)

Block for 1 token

Examples

let mut limiter = Builder::default().build();
let mut handle = limiter.make_handle();

thread::spawn(move || { limiter.run() });

let mut threads = Vec::new();

for i in 0..2 {
    let mut handle = handle.clone();
    threads.push(thread::spawn(move || {
        for x in 0..5 {
            handle.wait();
            println!(".");
        }
    }));
}

source

pub fn wait_for(&mut self, count: usize)

Block for count tokens

Examples

let mut limiter = Builder::default().build();
let mut handle = limiter.make_handle();

thread::spawn(move || { limiter.run() });

let mut threads = Vec::new();

for i in 0..2 {
    let mut handle = handle.clone();
    threads.push(thread::spawn(move || {
        for x in 0..5 {
            handle.wait_for(1);
            println!(".");
        }
    }));
}

source

pub fn try_wait(&mut self) -> Result<(), ()>

Non-blocking wait for one token. Returns Ok(()) if no wait required. Returns Err(()) if wait would block.

Examples

let mut limiter = Builder::new().build();
let mut handle = limiter.make_handle();

if handle.try_wait().is_ok() {
    println!("token granted");
} else {
    println!("would block");
}

source

pub fn try_wait_for(&mut self, count: usize) -> Result<(), ()>

Non-blocking wait for count token. Returns Ok(()) if no wait required. Returns Err(()) if wait would block.

Examples

let mut limiter = Builder::new().build();
let mut handle = limiter.make_handle();

if handle.try_wait_for(2).is_ok() {
    println!("tokens granted");
} else {
    println!("would block");
}