Struct ThrottledWatchReceiver 

pub struct ThrottledWatchReceiver { /* private fields */ }

Coalesces bursts of watch notifications and emits at most once per interval.

Implementations

impl ThrottledWatchReceiver

pub fn new(rx: Receiver, interval: Duration) -> Self

Creates a throttling wrapper around a raw watcher Receiver.

pub async fn recv(&mut self) -> Option<FileWatcherEvent>

Receives the next event, enforcing the configured minimum delay after the previous emission.