Struct lunatic::LinkMailbox

pub struct LinkMailbox<T: Serialize + DeserializeOwned> { /* fields omitted */ }

Mailbox for linked processes.

When a process is linked to others it will also receive messages if one of the others dies.

Implementations

impl<T: Serialize + DeserializeOwned> LinkMailbox<T>

pub fn receive(&self) -> Message<T>

Gets next message from process’ mailbox.

If the mailbox is empty, this function will block until a new message arrives.

pub fn receive_timeout(&self, timeout: Duration) -> Message<T>

Same as [receive], but only waits for the duration of timeout for the message.

pub fn tag_receive(&self, tag: Tag) -> Message<T>

Gets a message with a specific tag from the mailbox.

If the mailbox is empty, this function will block until a new message arrives.

pub fn tag_receive_timeout(&self, tag: Tag, timeout: Duration) -> Message<T>

Same as [tag_receive], but only waits for the duration of timeout for the tagged message.

Trait Implementations

impl<T: Debug + Serialize + DeserializeOwned> Debug for LinkMailbox<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T: Serialize + DeserializeOwned> TransformMailbox<T> for LinkMailbox<T>

fn catch_link_panic(self) -> LinkMailbox<T>

fn panic_if_link_panics(self) -> Mailbox<T>