Struct PcmReader 

pub struct PcmReader { /* private fields */ }

Threaded PCM reader — direct port of pcm_async.

Reads raw PCM from any Read source on a background thread, converts S16→f32 if needed, and fills a ring buffer.

Implementations

impl PcmReader

pub fn new(source: Box<dyn Read + Send>, config: PcmReaderConfig) -> Self

Create and immediately start the reader thread.

pub fn pop_ms(&self, ms: i32) -> Vec<f32>

Pop up to ms milliseconds of audio from the ring buffer. Returns fewer samples if not enough are available.

pub fn available_samples(&self) -> usize

Number of unread samples currently in the ring buffer.

pub fn is_eof(&self) -> bool

Whether the source has reached EOF.

pub fn stop(&mut self)

Signal the reader thread to stop.

Trait Implementations

impl Drop for PcmReader

fn drop(&mut self)

Executes the destructor for this type.