Skip to main content

audit

graphrefly_operators::temporal

Function audit 

Source 
pub fn audit(
    core: &Core,
    binding: &Arc<dyn ProducerBinding>,
    source: NodeId,
    ms: u64,
) -> NodeId
Expand description

On the first upstream DATA in each window, starts a ms timer. When the timer fires, emits the latest value received during the window. Subsequent DATA values within the window update the stored value but do NOT restart the timer.

Differs from debounce: debounce resets on each DATA (quiet-time); audit fires at a fixed interval after the first DATA in the window.