Skip to main content

debounce

graphrefly_operators::temporal

Function debounce 

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

Emits after delay of quiet — each new upstream DATA resets the timer.

On upstream COMPLETE, flushes pending (if any) then completes. On upstream ERROR, cancels and propagates immediately.