Struct tikv_util::mpsc::Receiver

pub struct Receiver<T> {
    receiver: Receiver<T>,
    state: Arc<State>,
}

The receive end of a channel.

Fields

receiver: Receiver<T>

state: Arc<State>

Implementations

impl<T> Receiver<T>

pub fn len(&self) -> usize

Returns the number of messages in the channel.

pub fn is_empty(&self) -> bool

Returns true if the channel is empty.

Note: Zero-capacity channels are always empty.

pub fn recv(&self) -> Result<T, RecvError>

Blocks the current thread until a message is received or the channel is empty and disconnected.

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

Attempts to receive a message from the channel without blocking.

pub fn recv_timeout(&self, timeout: Duration) -> Result<T, RecvTimeoutError>

Waits for a message to be received from the channel, but only for a limited time.

Trait Implementations

impl<T> Drop for Receiver<T>

fn drop(&mut self)

Executes the destructor for this type.