Trait tokio::sync::mpsc::chan::Semaphore

pub(crate) trait Semaphore {
    // Required methods
    fn is_idle(&self) -> bool;
    fn add_permit(&self);
    fn add_permits(&self, n: usize);
    fn close(&self);
    fn is_closed(&self) -> bool;
}

Required Methods

fn is_idle(&self) -> bool

fn add_permit(&self)

fn add_permits(&self, n: usize)

fn close(&self)

fn is_closed(&self) -> bool

Implementors

impl Semaphore for tokio::sync::mpsc::bounded::Semaphore

impl Semaphore for tokio::sync::mpsc::unbounded::Semaphore