Struct ChannelState 

struct ChannelState<T> {
    data: Option<VecDeque<T>>,
    recv_wakers: Option<Vec<Waker>>,
}

Fields

data: Option<VecDeque<T>>

Buffered data.

This is None when the receiver is gone.

recv_wakers: Option<Vec<Waker>>

Wakers for the receiver side.

The receiver will be pending if the buffer is empty and there are senders left (otherwise this is set to None).

Implementations

impl<T> ChannelState<T>

fn take_recv_wakers(&mut self) -> Vec<Waker>

Get all recv_wakers and replace with identically-sized buffer.

The wakers should be woken AFTER the lock to this state was dropped.

Panics

Assumes that channel is NOT closed yet, i.e. that recv_wakers is not None.

Trait Implementations

impl<T: Debug> Debug for ChannelState<T>

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

Formats the value using the given formatter.