Struct MessageQueue 

pub struct MessageQueue<'a> { /* private fields */ }

Mutable scoped view of messages retained until their delivery boundary.

Implementations

impl<'a> MessageQueue<'a>

pub fn count(&self) -> usize

Returns the number of queued items owned by this middleware.

pub fn latest(&self) -> Option<QueuedMessageView<'_>>

Returns the newest message available to this context.

pub fn find(&self, id: &str) -> Option<QueuedMessageView<'_>>

Returns one owned item by its revision identity.

pub fn enqueue( &mut self, id: &str, boundary: QueuedMessageBoundary, event: MessageEvent, ) -> Result<bool>

Appends one prepared message, or returns false when it is full or duplicated.

pub fn replace( &mut self, id: &str, replacement_id: &str, event: MessageEvent, ) -> Result<bool>

Atomically replaces one owned item while preserving its queue position.