Struct SpmcPlayback 

pub struct SpmcPlayback<T: Transcendental, const BUF: usize, const CAP: usize> { /* private fields */ }

An IoPlayback that pushes signal blocks into a lock-free SPSC queue.

Each write_output call wraps the signal data into a TelemetryBlock and pushes it into a SpscQueue. No allocations, no locks — safe to call from the RT signal path. A non-RT collector drains the queue.

Implementations

impl<T: Transcendental, const BUF: usize, const CAP: usize> SpmcPlayback<T, BUF, CAP>

pub fn new( queue: Arc<SpscQueue<TelemetryBlock<T, BUF>, CAP>>, channels: usize, sample_rate: f32, ) -> Self

Create an SPSC-based playback that writes to queue.

pub fn queue(&self) -> &Arc<SpscQueue<TelemetryBlock<T, BUF>, CAP>>

Return the shared queue for draining on the non-RT side.

Trait Implementations

impl IoPlayback for SpmcPlayback<f32, 256, 64>

fn write_output(&self, channel: usize, src: &[f32]) -> usize

Write output samples for one channel from src.

fn num_output_channels(&self) -> usize

Number of playback channels.