Struct MemoryPcmSink 

pub struct MemoryPcmSink { /* private fields */ }

In-memory PcmSink that records every written buffer and flush.

This is the deterministic test backend for the sink side of the PCM fabric: written buffers accumulate in order and can be inspected through buffers or taken with into_buffers, while flushes are counted.

Examples

use sim_lib_stream_audio::{MemoryPcmSink, PcmBuffer, PcmSink, PcmSpec};

let spec = PcmSpec::i16(1, 48_000)?;
let mut sink = MemoryPcmSink::new(spec);
sink.write_buffer(PcmBuffer::i16(spec, 1, vec![7])?)?;
sink.flush()?;
assert_eq!(sink.buffers().len(), 1);
assert_eq!(sink.flush_count(), 1);

Implementations

impl MemoryPcmSink

pub fn new(spec: PcmSpec) -> Self

Builds an empty sink that accepts buffers matching spec.

pub fn buffers(&self) -> &[PcmBuffer]

Returns the buffers written so far, in write order.

pub fn flush_count(&self) -> usize

Returns how many times flush has been called.

pub fn into_buffers(self) -> Vec<PcmBuffer>

Consumes the sink and returns the recorded buffers.

Trait Implementations

impl Clone for MemoryPcmSink

fn clone(&self) -> MemoryPcmSink

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for MemoryPcmSink

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl PcmSink for MemoryPcmSink

fn spec(&self) -> &PcmSpec

Returns the audio format this sink accepts.

fn write_buffer(&mut self, buffer: PcmBuffer) -> Result<()>

Writes one buffer to the sink.

fn flush(&mut self) -> Result<()>

Flushes any pending output, marking a stream boundary.