Struct Bulkhead 

pub struct Bulkhead { /* private fields */ }

A concurrency cap.

Implementations

impl Bulkhead

pub fn new(capacity: usize) -> Self

Build a bulkhead allowing up to capacity concurrent permits.

Panics

Panics if capacity is zero.

pub async fn acquire(&self) -> Result<BulkheadPermit, ToolkitError>

Wait until a slot is free, then take it.

pub fn try_acquire(&self) -> Option<BulkheadPermit>

Try to take a slot without waiting. Returns None if all slots are busy.

pub fn available_permits(&self) -> usize

Number of currently free slots.

pub fn capacity(&self) -> usize

Total capacity (slots when fully idle).

pub fn close(&self)

Close the bulkhead — pending acquires will return ToolkitError::BulkheadClosed.

Trait Implementations

impl Clone for Bulkhead

fn clone(&self) -> Bulkhead

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Bulkhead

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

Formats the value using the given formatter.