Struct CommandQueue 

pub struct CommandQueue { /* private fields */ }

Command queue for batching protocol commands before transmission. Commands are aggregated into larger packets to improve bandwidth utilization.

Implementations

impl CommandQueue

pub fn new(capacity: usize) -> Self

Creates a new command queue with the specified capacity.

pub fn enqueue(&mut self, command: ProtocolCommand) -> bool

Enqueues a protocol command for later processing. Returns true if the queue should be flushed (reached max size).

pub fn len(&self) -> usize

Returns the number of queued commands.

pub fn is_empty(&self) -> bool

Returns true if the queue is empty.

pub fn drain(&mut self) -> impl Iterator<Item = ProtocolCommand> + '_

Drains all commands from the queue for processing.

pub fn iter(&self) -> impl Iterator<Item = &ProtocolCommand>

Returns an iterator over the commands without draining.

pub fn clear(&mut self)

Clears all pending commands.

Trait Implementations

impl Debug for CommandQueue

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

Formats the value using the given formatter.

impl Default for CommandQueue

fn default() -> Self

Returns the “default value” for a type.