Struct StreamSynchronizer 

pub struct StreamSynchronizer { /* private fields */ }

Multi-stream synchronizer

Implementations

impl StreamSynchronizer

pub fn new(config: SyncConfig) -> Self

Create new synchronizer with configuration

pub fn add_stream(&mut self, stream_id: String)

Add a stream to synchronize

pub fn push(&mut self, sample: TimestampedSample) -> IoResult<()>

Push sample from a stream

pub fn try_sync(&mut self) -> IoResult<HashMap<String, Array1<f32>>>

Try to get synchronized samples from all streams Returns HashMap of stream_id -> interpolated sample

pub fn buffer_len(&self, stream_id: &str) -> usize

Get number of buffered samples for a stream

pub fn clear(&mut self)

Clear all buffers

pub fn stream_ids(&self) -> Vec<String>

Get registered stream IDs

Trait Implementations

impl Default for StreamSynchronizer

fn default() -> Self

Returns the “default value” for a type.