Struct StreamingDataPipeline 

pub struct StreamingDataPipeline<T: Copy + Clone + DataPoint, const N: usize> { /* private fields */ }

Streaming data pipeline that connects data sources to animated charts

Implementations

impl<T: Copy + Clone + DataPoint, const N: usize> StreamingDataPipeline<T, N>

pub fn new(update_rate_hz: u32) -> Self

Create a new streaming data pipeline

pub fn with_config(_update_rate_hz: u32, config: PipelineConfig) -> Self

Create a new streaming data pipeline with custom configuration

pub fn add_source( &mut self, source: StreamingDataSource<N>, ) -> ChartResult<usize>

Add a data source to the pipeline

pub fn update(&mut self, delta_time: Milliseconds) -> ChartResult<bool>

Update the pipeline with new data

pub fn current_data(&self) -> impl Iterator<Item = T> + '_

Get current data from the pipeline

pub fn metrics(&self) -> &PipelineMetrics

Get pipeline metrics

pub fn source_count(&self) -> usize

Get number of active sources