Struct DatEventSink 

pub struct DatEventSink { /* private fields */ }

Writes a Prophesee .dat CD recording a window at a time — the inverse of read_dat.

The % header and the event-type/size pair are written on the first non-empty append, because the header carries % Width/% Height and those come from the first stream’s sensor size. After that every append is a run of 8-byte records with nothing to fix up, so the file is readable at any point.

Timestamps are u32 microseconds, which is the format’s own width: it wraps after ~71 minutes and the format offers no high half, so a recording longer than that is rejected rather than silently wrapped.

Implementations

impl DatEventSink

pub fn create(path: impl AsRef<Path>) -> Result<Self, IoError>

Trait Implementations

impl EventSink for DatEventSink

fn append(&mut self, stream: &EventStream) -> Result<(), IoError>

Appends one window’s events. Empty windows are a no-op. The first non-empty window fixes the sensor size and time base for the whole file.

fn n_events(&self) -> usize

Total events written so far.

fn flush(&mut self) -> Result<(), IoError>

Pushes buffered data at the file without closing it, so a crash mid-recording keeps everything appended so far. Formats that only become readable at finish (npz, rosbag) still flush their bytes, but the file stays incomplete until then.

fn finish(self: Box<Self>) -> Result<(), IoError>

Writes whatever the format keeps for last — an index, a patched header — and closes.