Struct PendingMessageQueue 

pub struct PendingMessageQueue { /* private fields */ }

A FIFO of AgentMessages waiting to be injected at a drain point. Mirrors TS PendingMessageQueue. Clone so Agent can keep a steering instance and a follow-up instance independently.

Implementations

impl PendingMessageQueue

pub fn new(mode: QueueMode) -> Self

pub fn mode(&self) -> QueueMode

pub fn enqueue(&mut self, message: AgentMessage)

Append a message to the tail. Mirrors TS enqueue.

pub fn is_empty(&self) -> bool

pub fn len(&self) -> usize

pub fn try_drain(&mut self) -> Vec<AgentMessage>

Drain queued messages per QueueMode:

• All: return and remove every queued message, in enqueue order.
• OneAtATime: return and remove only the oldest, leaving the rest.

Returns an empty Vec when nothing is queued (the loop treats an empty drain as “no injection”). Mirrors TS tryDrain.

Trait Implementations

impl Clone for PendingMessageQueue

fn clone(&self) -> PendingMessageQueue

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PendingMessageQueue

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

Formats the value using the given formatter.

impl Default for PendingMessageQueue

fn default() -> PendingMessageQueue

Returns the “default value” for a type.