Struct BagSliceSource 

pub struct BagSliceSource { /* private fields */ }

In-place SliceSource for rosbags. The bag’s own chunk index (ChunkInfo) gives each chunk’s byte offset and time range, so time slicing seeks straight to the overlapping chunks and decompresses only those — no full read, bounded memory. Event counts aren’t in the index, so n_events/slice_index decode the target chunks once and cache the per-chunk cumulative counts; time slicing never triggers that.

Trait Implementations

impl SliceSource for BagSliceSource

fn sensor_size(&self) -> (usize, usize)

fn timestamp_scale_ms(&self) -> f64

fn n_events(&self) -> usize

Total events in the file.

fn time_span(&self) -> (i64, i64)

(t_min, t_max) in microseconds across the whole file; (0, 0) when empty.

fn frames(&self, t0: i64, t1: i64) -> Result<Vec<(i64, EventFrame)>, IoError>

The intensity (APS) frames a DAVIS recorded alongside its events, those whose timestamp lies in the half-open window [t0, t1) (µs), paired with that timestamp.

fn imu(&self, t0: i64, t1: i64) -> Result<Vec<ImuSample>, IoError>

The IMU samples in [t0, t1) (µs).

fn camera(&self) -> Result<Option<Camera>, IoError>

The camera intrinsics the recording carries, if it carries any.

fn slice_time(&self, t0: i64, t1: i64) -> Result<EventStream, IoError>

Events whose timestamp (µs) lies in the half-open window [t0, t1).

fn slice_index(&self, i0: usize, i1: usize) -> Result<EventStream, IoError>

Events whose index lies in [i0, i1) (clamped to the file).

fn slice_time_into( &self, t0: i64, t1: i64, sink: &mut dyn EventConsumer, ) -> Result<(), IoError>

Streams the events of [t0, t1) into sink, in decode order, without keeping them.

fn pixel_counts(&self) -> Result<Vec<u64>, IoError>

Per-pixel event counts over the whole file (row-major width·height), out-of-bounds events dropped — what the reader’s hot-pixel pre-scan needs. The default tallies through slice_index in bounded chunks; a source that can read coordinates alone (HDF5) overrides this to skip the t/p columns and stream construction, which is most of the work.