Struct Mailbox 

pub struct Mailbox<T> { /* private fields */ }

Collects messages from a channel.

recv and try_recv both take &self, so a mailbox can be held behind a shared reference and moved between threads. One consumer at a time is still the rule: a transport whose consumer parks in recv may hold an internal lock for the duration.

Implementations

impl<T: Send + 'static> Mailbox<T>

pub fn of<C: Consume<T> + Send + Sync + 'static>(consumer: C) -> Self

Wraps a transport-specific consumer.

Transports build ends through this; everyone else gets them from Transport::channel.

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

Waits for the next message, parking rather than spinning.

Err(Disconnected) means every producer is gone and the queue is drained — the only unambiguous way for a consumer to learn the channel is closed.

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

Takes the next message if one is already waiting, without blocking.

The UI thread polls here rather than calling Mailbox::recv, because it has to keep servicing the event loop between messages.

Trait Implementations

impl<T> Clone for Mailbox<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T> Debug for Mailbox<T>

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

Formats the value using the given formatter.