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 dropped_samples(&self) -> u64

Total number of samples dropped due to ring buffer overflow.

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.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.