Struct lunatic::channel::Receiver

pub struct Receiver<T> { /* fields omitted */ }

The receiving side of a channel.

Receivers can be cloned and shared among processes. When all receivers associated with a channel are dropped, the channel becomes closed.

Implementations

impl<T> Receiver<T> where
    T: Serialize + DeserializeOwned, 

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

Receives a message from the channel.

If the channel is empty, this method waits until there is a message.

If the channel is closed, this method receives a message or returns an error if there are no more messages.

Trait Implementations

impl<T> Clone for Receiver<T>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<'de, T> Deserialize<'de> for Receiver<T> where
    T: Serialize + DeserializeOwned, 

fn deserialize<D>(deserializer: D) -> Result<Receiver<T>, D::Error> where
    D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl<T> Serialize for Receiver<T> where
    T: Serialize + DeserializeOwned, 

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error> where
    S: Serializer, 

Serialize this value into the given Serde serializer.