Struct StreamMultiplexer 

pub struct StreamMultiplexer { /* private fields */ }

Stream multiplexer - combines multiple streams into one

Implementations

impl StreamMultiplexer

pub fn new(config: MultiplexConfig) -> Self

Create new multiplexer

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

Add input stream

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

Push sample from a stream

pub fn next_sample(&mut self) -> Option<TimestampedSample>

Get next multiplexed sample

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

Get number of buffered samples for a stream

pub fn total_buffered(&self) -> usize

Get total buffered samples across all streams

pub fn clear(&mut self)

Clear all buffers

Trait Implementations

impl Default for StreamMultiplexer

fn default() -> Self

Returns the “default value” for a type.