Struct WindowLoader 

pub struct WindowLoader<'a> { /* private fields */ }

Streams HaloWindows of a RecordingSource, reading ahead on a background thread.

Implementations

impl<'a> WindowLoader<'a>

pub fn new(source: &'a dyn RecordingSource) -> Self

Loader over all channels of source.

pub fn with_channels( source: &'a dyn RecordingSource, channels: Vec<usize>, ) -> Self

Loader over channels of source, in that order.

pub fn source(&self) -> &'a dyn RecordingSource

The recording read.

pub fn channels(&self) -> &[usize]

Channels read, in buffer order.

pub fn stream<F>(&self, windows: &[HaloWindow], f: F) -> DspResult<()>

where F: FnMut(&HaloWindow, &[f32]) -> DspResult<()>,

Calls f(&window, samples) for every window of windows, in order: samples is the channel-major [channels, window.read_len()] block of scaled values (RecordingSource::read). Any subset works (a full super::ChunkSchedule, every n-th window, isolated windows); the next window is read while f runs.

pub fn stream_while<F>(&self, windows: &[HaloWindow], f: F) -> DspResult<()>

where F: FnMut(&HaloWindow, &[f32]) -> DspResult<bool>,

Like Self::stream until f returns false (e.g. once enough data is gathered): no window after that one is passed to f, and reading stops.

pub fn stream_stored<F>(&self, windows: &[HaloWindow], f: F) -> DspResult<()>

where F: FnMut(&HaloWindow, &[u8]) -> DspResult<()>,

Like Self::stream with the stored values (RecordingSource::read_stored): info().format little-endian bytes, channel-major, before gain and offset.

pub fn stream_stored_while<F>( &self, windows: &[HaloWindow], f: F, ) -> DspResult<()>

where F: FnMut(&HaloWindow, &[u8]) -> DspResult<bool>,

Like Self::stream_stored until f returns false.

pub fn stream_owned_while<F>( &self, windows: &[HaloWindow], f: F, ) -> DspResult<()>

where F: FnMut(&HaloWindow, Vec<f32>) -> DspResult<bool>,

Like Self::stream_while, handing f each window as an owned buffer: the reading thread allocates and fills it, so a consumer that moves it on (e.g. into a device upload) copies nothing on the calling thread. At most one window is read ahead.

pub fn stream_stored_owned_while<F>( &self, windows: &[HaloWindow], f: F, ) -> DspResult<()>

where F: FnMut(&HaloWindow, Vec<u8>) -> DspResult<bool>,

Self::stream_owned_while with the stored values (RecordingSource::read_stored).