Struct StochasticMpmcReceiver

pub struct StochasticMpmcReceiver<T>(/* private fields */);

Receiver for a stochastic MPMC channel. Create one using stochastic_channel(). This receiver can be cheaply cloned, which will increase the receiver count. Dropping a receiver will decrease the receiver count.

Implementations

impl<T> StochasticMpmcReceiver<T>

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

Receive an item, or return None if no items are available right now. If there are no senders, an error is returned.

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

Block the current thread until an item can be received, time has run out, or there are no more senders. If time has run out or there are no more senders, an error is returned.

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

Block the current thread until an item can be received or there are no more senders. If there are no more senders, an error is returned.

Trait Implementations

impl<T> Clone for StochasticMpmcReceiver<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

const fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T> Drop for StochasticMpmcReceiver<T>

fn drop(&mut self)

Executes the destructor for this type.

impl<T> IntoIterator for StochasticMpmcReceiver<T>

type IntoIter = StochasticMpmcReceiverIterator<T>

Which kind of iterator are we turning this into?

type Item = T

The type of the elements being iterated over.

fn into_iter(self) -> Self::IntoIter

Creates an iterator from a value.