Struct crossbeam_channel::flavors::zero::Channel

pub(crate) struct Channel<T> {
    inner: Mutex<Inner>,
    _marker: PhantomData<T>,
}

Zero-capacity channel.

Fields

inner: Mutex<Inner>

Inner representation of the channel.

_marker: PhantomData<T>

Indicates that dropping a Channel<T> may drop values of type T.

Implementations

impl<T> Channel<T>

pub(crate) fn new() -> Self

Constructs a new zero-capacity channel.

pub(crate) fn receiver(&self) -> Receiver<'_, T>

Returns a receiver handle to the channel.

pub(crate) fn sender(&self) -> Sender<'_, T>

Returns a sender handle to the channel.

fn start_send(&self, token: &mut Token) -> bool

Attempts to reserve a slot for sending a message.

pub(crate) unsafe fn write(&self, token: &mut Token, msg: T) -> Result<(), T>

Writes a message into the packet.

fn start_recv(&self, token: &mut Token) -> bool

Attempts to pair up with a sender.

pub(crate) unsafe fn read(&self, token: &mut Token) -> Result<T, ()>

Reads a message from the packet.

pub(crate) fn try_send(&self, msg: T) -> Result<(), TrySendError<T>>

Attempts to send a message into the channel.

pub(crate) fn send( &self, msg: T, deadline: Option<Instant>, ) -> Result<(), SendTimeoutError<T>>

Sends a message into the channel.

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

Attempts to receive a message without blocking.

pub(crate) fn recv( &self, deadline: Option<Instant>, ) -> Result<T, RecvTimeoutError>

Receives a message from the channel.

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

Disconnects the channel and wakes up all blocked senders and receivers.

Returns true if this call disconnected the channel.

pub(crate) fn len(&self) -> usize

Returns the current number of messages inside the channel.

pub(crate) fn capacity(&self) -> Option<usize>

Returns the capacity of the channel.

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

Returns true if the channel is empty.

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

Returns true if the channel is full.