Struct PortBuffer 

pub struct PortBuffer { /* private fields */ }

A buffer that sits between an output port and an input port.

Implementations

impl PortBuffer

pub fn new(strategy: BufferStrategy, label: &str) -> Self

Create a new port buffer with the given strategy.

pub fn push(&mut self, token: FrameToken) -> bool

Push a frame token into the buffer.

Returns true if the frame was accepted, false if it was dropped due to overflow (for bounded strategies).

pub fn pop(&mut self) -> Option<FrameToken>

Pop the next frame token from the buffer.

pub fn peek(&self) -> Option<&FrameToken>

Peek at the next frame token without removing it.

pub fn len(&self) -> usize

Get the current number of frames in the buffer.

pub fn is_empty(&self) -> bool

Check whether the buffer is empty.

pub fn status(&self) -> BufferStatus

Get the current buffer status.

pub fn strategy(&self) -> BufferStrategy

Get the buffering strategy.

pub fn max_capacity(&self) -> usize

Get the maximum capacity (0 for unbounded).

pub fn total_pushed(&self) -> u64

Get the total number of frames pushed.

pub fn total_popped(&self) -> u64

Get the total number of frames popped.

pub fn dropped(&self) -> u64

Get the number of dropped frames.

pub fn label(&self) -> &str

Get the buffer label.

pub fn clear(&mut self)

Clear all buffered frames.

pub fn drain_all(&mut self) -> Vec<FrameToken>

Drain all frames from the buffer as a vector.

pub fn fill_ratio(&self) -> f64

Get fill ratio (0.0 to 1.0). Returns 0.0 for unbounded buffers.

Trait Implementations

impl Display for PortBuffer

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

Formats the value using the given formatter.