Struct tokio::sync::mpsc::bounded::Semaphore

pub(crate) struct Semaphore {
    pub(crate) semaphore: Semaphore,
    pub(crate) bound: usize,
}

Channel semaphore is a tuple of the semaphore implementation and a usize representing the channel bound.

Fields

semaphore: Semaphore

bound: usize

Trait Implementations

impl Debug for Semaphore

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

Formats the value using the given formatter.

impl Semaphore for Semaphore

fn add_permit(&self)

fn add_permits(&self, n: usize)

fn is_idle(&self) -> bool

fn close(&self)

fn is_closed(&self) -> bool