Struct Channel 

pub struct Channel<T> { /* private fields */ }

A bounded multi-producer multi-consumer channel.

Implementations

impl<T> Channel<T>

pub fn new(capacity: usize) -> Arc<Self>

pub fn try_send(&self, value: T) -> Result<(), ChannelError<T>>

Try to send a value.

pub fn try_recv(&self) -> Result<T, ChannelError<()>>

Try to receive a value.

pub fn register_send_wait(&self, waker: Waker)

Register to wait for send.

pub fn register_recv_wait(&self, waker: Waker)

Register to wait for receive.

pub fn close(&self)

Close the channel.

pub fn is_closed(&self) -> bool

Check if closed.

pub fn len(&self) -> usize

Get current length.

pub fn is_empty(&self) -> bool

Check if empty.