Struct RemoteSource 

pub struct RemoteSource { /* private fields */ }

The recording a Session has open, as a RecordingSource: samples (scaled f32) read on the server as sample views, in pieces under its limits. For small reads (a window of waveforms, the value under the cursor); a whole recording belongs on the server.

Implementations

impl RemoteSource

pub fn new(session: Arc<Session>, handle: Handle) -> Result<Self, StreamError>

The recording session has open; calls run on handle (the runtime that drives the session’s connection).

Trait Implementations

impl RecordingSource for RemoteSource

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

Samples of channels, channel-major, fetched as sample views and reassembled.

fn info(&self) -> &RecordingInfo

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

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.