Struct MessageDebouncer 

pub struct MessageDebouncer { /* private fields */ }

Accumulates rapid inbound messages per sender and fires a single combined message after the debounce window elapses without new input.

Implementations

impl MessageDebouncer

pub fn new(window: Duration) -> Self

Create a new debouncer with the given window. A zero duration disables debouncing (all messages pass through).

pub fn enabled(&self) -> bool

Returns true when debouncing is active (non-zero window).

pub async fn debounce(&self, sender_key: &str, message: &str) -> DebounceResult

Submit a message for debouncing.

• If the window is zero, returns DebounceResult::Passthrough immediately.
• Otherwise, accumulates the message under sender_key and returns DebounceResult::Pending with a receiver that will eventually yield the concatenated messages once the window expires.

Each new message resets the timer. When the timer fires it concatenates all accumulated messages with "\n" and sends them through the oneshot channel.