Struct Debouncer 

pub struct Debouncer { /* private fields */ }

Per-session debounce controller.

State is two atomics — an epoch counter bumped on every Self::poke, and a pending flag that gates spawning the debounce task. The task itself is lazy: it spawns on the first poke after an idle period, sleeps the debounce window, re-reads the epoch, and either re-sleeps (more pokes arrived during the window) or invokes the supplied runner and exits. No task runs while the session is quiescent.

runner is Arc<dyn Fn> — shareable across the loop. The caller (DiffSubsystem::poke_session) captures the subsystem Arc + session key into the closure.

Implementations

impl Debouncer

pub fn new(window: Duration) -> Self

pub fn window(&self) -> Duration

pub fn poke<F>(&self, runner: F)

where F: Fn() + Send + Sync + 'static,

Bump the epoch. If no debounce task is in flight, spawn one that sleeps the window, re-reads the epoch, and either re-sleeps (more pokes) or invokes runner and exits.

runner runs on the tokio runtime (the debounce task is itself a tokio task). Inside the runner, the production call site schedules the actual recompute on spawn_blocking; the runner closure stays light.

Trait Implementations

impl Debug for Debouncer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.