Struct StreamingResampler 

pub struct StreamingResampler { /* private fields */ }

Stateful streaming resampler that maintains SoX instances across chunks. This is used by AudioPipeline for memory-efficient streaming resampling.

FIX for Defect 33: Pre-allocate all buffers to avoid heap allocation in process_chunk

Implementations

impl StreamingResampler

pub fn from_rate(&self) -> u32

pub fn to_rate(&self) -> u32

pub fn max_output_len_for_input(&self, input_samples: usize) -> usize

Naive ratio upper bound, in interleaved samples, on the output a single process_chunk_* call can return.

Per-call Soxr output is now capped (via slicing the pre-allocated scratch to this bound) inside process_chunk_*, so this is a valid single-call ceiling: any excess input is buffered by Soxr and recovered on later calls. Callers reserving an output/leftover buffer for one render-loop input chunk should size it with this method.

pub fn max_output_samples_per_chunk(&self) -> usize

Absolute hard upper bound, in interleaved samples, on the output a single process_chunk_* call can return for this resampler.

This equals the pre-allocated interleaved_output capacity. With per-call output now capped to the naive ratio bound (see max_output_len_for_input), max_output_len_for_input is the right size for per-call reserves; this method remains the absolute ceiling tied to the internal buffer capacity.

pub fn input_frames_for_output_frames(&self, output_frames: usize) -> usize

pub fn new( channels: usize, from_rate: u32, to_rate: u32, ) -> Result<Self, ResamplerError>

Create a new streaming resampler with default (linear) phase and High quality

pub fn with_phase( channels: usize, from_rate: u32, to_rate: u32, phase: PhaseResponse, ) -> Result<Self, ResamplerError>

Create a new streaming resampler with specified phase response (High quality)

Returns Err if Soxr initialization fails (e.g., invalid sample rates like 0 Hz)

pub fn with_quality( channels: usize, from_rate: u32, to_rate: u32, phase: PhaseResponse, quality: ResampleQuality, ) -> Result<Self, ResamplerError>

Create a new streaming resampler with specified phase response and quality level

FIX for Defect 30: Allow quality configuration FIX for Defect 33: Pre-allocate all buffers to avoid heap allocation in process_chunk

Returns Err if Soxr initialization fails (e.g., invalid sample rates like 0 Hz)

pub fn process_chunk_borrowed<'a>( &'a mut self, input: &'a [f64], ) -> ResampleOutput<'a>

Process a chunk of interleaved audio and borrow the resampler-owned output.

Resampling processes only complete input frames; trailing samples where input.len() % channels != 0 are ignored to preserve existing behavior. The equal-rate bypass returns the original input slice unchanged. The borrowed slice remains valid until the next mutable resampler call.

pub fn process_chunk_append( &mut self, input: &[f64], output: &mut Vec<f64>, ) -> usize

Process a chunk and append the result directly to a caller-owned buffer.

pub fn process_chunk_into(&mut self, input: &[f64], output: &mut [f64]) -> usize

Process a chunk into a pre-allocated output buffer (zero-allocation version)

Returns the number of frames written to output. Output buffer must be large enough: output.len() >= input.len() * to_rate / from_rate + 64

pub fn reset(&mut self)

pub fn flush_borrowed(&mut self) -> ResampleOutput<'_>

Flush remaining samples and borrow the resampler-owned interleaved output.

pub fn flush_into(&mut self, output: &mut Vec<f64>) -> usize

Flush any remaining samples directly into a caller-owned output buffer.

pub fn flush(&mut self) -> Vec<f64>

Flush any remaining samples in the resampler’s internal buffers