Struct crossbeam_channel::flavors::never::Channel

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

Channel that never delivers messages.

Fields

_marker: PhantomData<T>

Implementations

impl<T> Channel<T>

pub(crate) fn new() -> Self

Creates a channel that never delivers messages.

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) unsafe fn read(&self, _token: &mut Token) -> Result<T, ()>

Reads a message from 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.

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

Returns the number of messages in the channel.

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

Returns the capacity of the channel.

Trait Implementations

impl<T> SelectHandle for Channel<T>

fn try_select(&self, _token: &mut Token) -> bool

Attempts to select an operation and returns true on success.

fn deadline(&self) -> Option<Instant>

Returns a deadline for an operation, if there is one.

fn register(&self, _oper: Operation, _cx: &Context) -> bool

Registers an operation for execution and returns true if it is now ready.

fn unregister(&self, _oper: Operation)

Unregisters an operation for execution.

fn accept(&self, token: &mut Token, _cx: &Context) -> bool

Attempts to select an operation the thread got woken up for and returns true on success.

fn is_ready(&self) -> bool

Returns true if an operation can be executed without blocking.

fn watch(&self, _oper: Operation, _cx: &Context) -> bool

Registers an operation for readiness notification and returns true if it is now ready.

fn unwatch(&self, _oper: Operation)

Unregisters an operation for readiness notification.