Struct StreamRingBuffer 

pub struct StreamRingBuffer { /* private fields */ }

Lock-free ring buffer for streaming

Uses atomic operations for single-producer single-consumer (SPSC) pattern. The buffer is power-of-two sized for efficient modulo operations.

Implementations

impl StreamRingBuffer

pub fn new(capacity: usize) -> Self

Create a new ring buffer with the given capacity. Capacity will be rounded up to the next power of 2.

pub fn capacity(&self) -> usize

Get the capacity of the buffer

pub fn len(&self) -> usize

Get the number of bytes available to read

pub fn is_empty(&self) -> bool

Check if the buffer is empty

pub fn available_space(&self) -> usize

Get available space for writing

pub fn backpressure(&self) -> &Backpressure

Get the backpressure signal

pub fn push(&self, data: &[u8]) -> Result<(), DCPError>

Push data into the buffer. Returns Err(Backpressure) if there’s not enough space.

pub fn pop(&self, buf: &mut [u8]) -> usize

Pop data from the buffer into the provided slice. Returns the number of bytes read.

pub fn peek(&self, buf: &mut [u8]) -> usize

Peek at data without consuming it. Returns the number of bytes peeked.

pub fn clear(&self)

Clear the buffer