Struct Gate 

struct Gate {
    empty_channels: AtomicUsize,
    send_wakers: Mutex<Option<Vec<(Waker, usize)>>>,
}

The “all channels have data” gate.

Fields

empty_channels: AtomicUsize

Number of currently empty (and still open) channels.

send_wakers: Mutex<Option<Vec<(Waker, usize)>>>

Wakers for the sender side, including their channel IDs.

This is None if the there are non-empty channels.

Implementations

impl Gate

fn wake_channel_senders(&self, id: usize)

Wake senders for a specific channel.

This is helpful to signal that the receiver side is gone and the senders shall now error.

fn decr_empty_channels(&self)

Trait Implementations

impl Debug for Gate

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

Formats the value using the given formatter.