Struct RequestLimiter 

pub struct RequestLimiter {
    semaphore: Arc<Semaphore>,
}

Limits unfinished original requests independently of their number of submissions.

Acquire once for each original request, then clone its permit into all of that request’s submissions. Capacity is released when the last owner drops it.

Fields

semaphore: Arc<Semaphore>

Implementations

impl RequestLimiter

pub fn try_new(max_inflight_requests: usize) -> Option<Self>

Returns None if the limit is zero or exceeds Tokio’s supported semaphore capacity.

pub async fn acquire(&self) -> Result<Arc<OwnedSemaphorePermit>, AcquireError>

Waits for one request slot and returns a permit shared by its submissions.

Cancelling a pending acquisition does not consume a slot. Once acquired, callers must retain the permit until every submission has finished, even if the original caller stops waiting for its response.

Trait Implementations

impl Clone for RequestLimiter

fn clone(&self) -> RequestLimiter

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.