Struct MergedRecording 

pub struct MergedRecording { /* private fields */ }

Channels of several recordings, side by side.

Implementations

impl MergedRecording

pub fn new(parts: Vec<MergeInput>) -> DspResult<Self>

Merges parts, each with the channels to take from it (None: all, in order).

Errors

DspError::InvalidConfig when there are no parts, a part’s channel does not exist, or the parts differ in sample rate or length.

Trait Implementations

impl RecordingSource for MergedRecording

fn info(&self) -> &RecordingInfo

fn read( &self, channels: &[usize], samples: Range<u64>, out: &mut [f32], ) -> DspResult<()>

Reads samples of every channel in channels into out, channel-major and scaled to each channel’s unit (ChannelInfo): out[i * n..(i + 1) * n] holds channels[i], where n = samples.end - samples.start.

fn read_stored( &self, channels: &[usize], samples: Range<u64>, out: &mut [u8], ) -> DspResult<()>

Reads the stored values (info().format, little-endian, before each channel’s gain and offset) of samples of every channel in channels into out, channel-major: out holds channels.len() · n · format.bytes() bytes. Lets pipelines move compact integer samples and scale them on the device.

fn read_native( &self, samples: Range<u64>, out: &mut [f32], ) -> Result<MemoryOrder, DspError>

Reads samples of every channel, scaled, in the order the source stores them, and returns that order: MemoryOrder::ChannelMajor fills out as Self::read of all channels; MemoryOrder::TimeMajor fills out[t * channels + c]. Whole-recording passes (min/max summaries) use it to skip the transposition read does for time-major sources.

fn chunk_samples(&self) -> Option<u64>

Samples per storage chunk along time, for formats stored in independently decoded chunks (Zarr, NWB, mtscomp). Reads covering whole multiples of it, aligned to it, decode each chunk once; None when every range costs the same (memory-mapped, in-memory, procedural).

fn read_channel( &self, channel: usize, samples: Range<u64>, out: &mut [f32], ) -> Result<(), DspError>

fn read_chunk( &self, channels: &[usize], samples: Range<u64>, ) -> Result<SignalChunk, DspError>

Reads into a newly allocated channel-major SignalChunk.