Struct hexodsp::monitor::MonitorProcessor

pub struct MonitorProcessor {
    rb_mon_con: Consumer<MonitorBufPtr>,
    rb_recycle_prod: Producer<MonitorBufPtr>,
    new_data: bool,
    procs: Vec<MonitorMinMax>,
}

Coordinates the processing of incoming MonitorBufs.

Fields

rb_mon_con: Consumer<MonitorBufPtr>

rb_recycle_prod: Producer<MonitorBufPtr>

new_data: bool

procs: Vec<MonitorMinMax>

Implementations

impl MonitorProcessor

pub fn new(
    rb_mon_con: Consumer<MonitorBufPtr>,
    rb_recycle_prod: Producer<MonitorBufPtr>
) -> Self

pub fn minmax_slice_for_signal(&self, idx: usize) -> (usize, &[(f32, f32)])

Helper function for tests, to access the current state of the min/max buffers.

fn process_mon_buf(&mut self, mon_buf: &mut MonitorBufPtr)

Internal helper function for process.

pub fn process(&mut self)

Processes all queued MonitorBuf instances and sends then back to the MonitorBackend thread after used for recycling.

pub fn check_new_data(&mut self) -> bool

Returns true, when a new data point was received. Resets the internal flag until the next time new data is received.