Struct Inbox 

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

A bounded FIFO receive queue for incoming ma messages.

Only the endpoint pushes messages into the inbox after validation. Expiry is determined per-message from the message’s own created_at + ttl. Consumers read via pop, peek, or drain.

Implementations

impl<T> Inbox<T>

pub fn new(capacity: usize) -> Self

Create an inbox with the given capacity.

pub fn push(&self, now: u64, expires_at: u64, item: T)

Push an item with a computed expiry timestamp.

expires_at should be message.created_at + message.ttl. Pass expires_at = 0 for items that never expire.

Used by endpoint implementations and for local in-process delivery (e.g. world routing a message directly to an object/room inbox).

pub fn pop(&self, now: u64) -> Option<T>

Pop the oldest non-expired item.

pub fn peek(&self, now: u64) -> Option<T>

where T: Clone,

Peek at the oldest non-expired item.

pub fn drain(&self, now: u64) -> Vec<T>

Drain all non-expired items in FIFO order.

pub fn len(&self) -> usize

Number of items in the queue (may include not-yet-evicted expired items).

pub fn is_empty(&self) -> bool

Whether the queue is empty.

Trait Implementations

impl<T> Clone for Inbox<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> Debug for Inbox<T>

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

Formats the value using the given formatter.