Struct Coalescer 

pub struct Coalescer { /* private fields */ }

Accumulates changed paths and releases them once the window has elapsed.

Deliberately holds no clock of its own: the caller supplies now, which is what makes the policy testable without sleeping.

Implementations

impl Coalescer

pub fn new(window: Duration) -> Self

pub fn push(&mut self, path: PathBuf, now: Instant)

Note a changed path. The window starts on the first path of a batch.

pub fn is_empty(&self) -> bool

pub fn time_remaining(&self, now: Instant) -> Option<Duration>

How long until the current batch is ready, if one is open.

pub fn take_if_ready(&mut self, now: Instant) -> Option<Vec<PathBuf>>

Take the batch if the window has elapsed. Returns None while it is still open, so a steady trickle of events still gets released on schedule rather than being deferred forever by each new arrival.

pub fn take(&mut self) -> Vec<PathBuf>

Take whatever is pending regardless of the window (used on shutdown).

Trait Implementations

impl Debug for Coalescer

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

Formats the value using the given formatter.