Struct Channel 

pub(crate) struct Channel<T> {
    pub(crate) queue: ConcurrentQueue<T>,
    pub(crate) send_ops: Event,
    pub(crate) recv_ops: Event,
    pub(crate) stream_ops: Event,
    pub(crate) closed_ops: Event,
    pub(crate) sender_count: AtomicUsize,
    pub(crate) receiver_count: AtomicUsize,
}

Fields

queue: ConcurrentQueue<T>

Inner message queue.

send_ops: Event

Send operations waiting while the channel is full.

recv_ops: Event

Receive operations waiting while the channel is empty and not closed.

stream_ops: Event

Stream operations while the channel is empty and not closed.

closed_ops: Event

Closed operations while the channel is not closed.

sender_count: AtomicUsize

The number of currently active Senders.

receiver_count: AtomicUsize

The number of currently active Receiverss.

Implementations

impl<T> Channel<T>

pub(crate) fn close(&self) -> bool

Closes the channel and notifies all blocked operations.

Returns true if this call has closed the channel and it was not closed already.