Struct SignalQueue 

pub struct SignalQueue { /* private fields */ }

Lock-free signal queue for audio/sensor data

Specialized queue for streaming f32 samples with batching support.

Implementations

impl SignalQueue

pub fn new(capacity: usize, batch_size: usize) -> Self

Create a new signal queue

pub fn write_samples(&self, samples: &[f32]) -> IoResult<()>

Write samples to the queue

pub fn read_batch(&self) -> IoResult<Array1<f32>>

Read a batch of samples

pub fn read_all(&self) -> Array1<f32>

Read all available samples

pub fn level(&self) -> usize

Get current queue level

pub fn capacity(&self) -> usize

Get queue capacity

pub fn fill_ratio(&self) -> f32

Get fill percentage (0.0 to 1.0)

pub fn underrun_count(&self) -> usize

Get underrun count

pub fn overrun_count(&self) -> usize

Get overrun count

pub fn reset_stats(&self)

Reset statistics