Struct TimeQueue 

pub struct TimeQueue<T> { /* private fields */ }

A struct to manage a sliding window of RR intervals and process heart rate variability (HRV) metrics. It stores a collection of RR intervals in data and calculates HRV using a custom or default pipeline.

Implementations

impl<T: Float + Sum<T> + Copy + 'static + Debug + Signed + AddAssign + Send + Sync + SubAssign + Into<f64> + FromPrimitive> TimeQueue<T>

where Box<dyn AnalysisPipeline<T>>: Default,

pub fn new(time: usize) -> Self

Creates a new TimeQueue with a sliding window of size time. A default pipeline is used.

Arguments

• time - The length of the time window (in ms).

pub fn set_pipeline(&mut self, pipeline: Box<dyn AnalysisPipeline<T>>)

Sets a custom pipeline to be used for HRV calculation.

Arguments

• pipeline - A boxed AnalysisPipeline that implements the HRV processing logic.

pub fn push(&mut self, rr_interval: T)

Pushes a new RR interval to the queue. The queue maintains the sliding window of RR intervals. Once the current time exceeds the defined window time, the oldest interval is removed.

pub fn get(&self) -> &[T]

Returns the current slice of the stored RR intervals.

pub fn get_hrv(&self) -> HrvMetrics<T>

Processes the current RR intervals using the pipeline and returns the HRV metrics.

This function calls the process method on the custom or default pipeline to calculate HRV.