Struct ockam_node::Mailbox

pub struct Mailbox { /* fields omitted */ }

A mailbox for encoded messages

Message type information can’t be exposed at this stage because they need to either be typed in the Relay or in the worker’s Context.

Implementations

impl Mailbox

pub fn new(rx: Receiver<RelayMessage>, tx: Sender<RelayMessage>) -> Self

Create a new mailbox

pub fn sender(&self) -> Sender<RelayMessage>

Return the sender of the mailbox.

pub async fn next(&mut self) -> Option<RelayMessage>

Get the next message from the mailbox

pub async fn requeue(&self, msg: RelayMessage)

If a message wasn’t expected, requeue it

Trait Implementations

impl Debug for Mailbox

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

Formats the value using the given formatter.