Struct crossbeam_channel::flavors::at::Channel

pub(crate) struct Channel {
    delivery_time: Instant,
    received: AtomicBool,
}

Channel that delivers a message at a certain moment in time

Fields

delivery_time: Instant

The instant at which the message will be delivered.

received: AtomicBool

true if the message has been received.

Implementations

impl Channel

pub(crate) fn new_deadline(when: Instant) -> Self

Creates a channel that delivers a message at a certain instant in time.

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

Attempts to receive a message without blocking.

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

Receives a message from the channel.

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

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 SelectHandle for Channel

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.