Struct ConcurrencyLimit 

pub struct ConcurrencyLimit { /* private fields */ }

A concurrency limit shared across calls: a semaphore with n permits (0 is treated as 1). Cheap to clone; every clone shares the permits. Use it when the work to bound is spread over separate calls (requests spawned from several write_batch invocations); within one call prefer map_concurrent.

Implementations

impl ConcurrencyLimit

pub fn new(n: usize) -> Self

A limit of n concurrent runs.

pub fn limit(&self) -> usize

The configured limit.

pub async fn run<T>(&self, fut: impl Future<Output = T>) -> T

Run fut once a permit is free.

Trait Implementations

impl Clone for ConcurrencyLimit

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConcurrencyLimit

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.