Struct Inbox 

pub struct Inbox(/* private fields */);

The messages arriving on a transport’s connection, readable apart from the transport.

recv borrows the transport for as long as it waits, so a program that waits for commands in one task while it publishes readings from another takes an inbox with MqttTransport::inbox and waits on that instead. The inbox follows the transport across reconnects.

Implementations

impl Inbox

pub async fn recv(&self) -> Result<Option<Message>>

Awaits the next message from any subscribed topic.

Returns

Some(message) for the next queued message, or None once the connection has ended and its reason has been reported.

Errors

Returns Error::Closed if the transport is not connected, or Error::Transport once, saying why, when the connection ended on its own.

Trait Implementations

impl Clone for Inbox

fn clone(&self) -> Inbox

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Inbox

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

Formats the value using the given formatter.

impl Default for Inbox

fn default() -> Inbox

Returns the “default value” for a type.