Struct InterruptCoalescer

pub(crate) struct InterruptCoalescer {
    batch_state: Cell<BatchSignalState>,
}

Signals the first completion immediately and defers subsequent interrupts until the batch ends.

Fields

batch_state: Cell<BatchSignalState>

Implementations

impl InterruptCoalescer

pub(crate) fn new() -> Self

Creates an idle InterruptCoalescer.

pub(crate) fn trigger_interrupt(&self, signal: impl FnOnce())

Calls signal immediately for the first completion, deferring the rest until complete.

pub(crate) fn complete(&self, signal: impl FnOnce())

Calls signal if any interrupts are pending due to interrupt coalescing.

pub(crate) fn active(&self) -> OptionFuture<Ready<()>>

Returns ready whenever a batch is active (Notified or Pending) so the event loop can flush and reset the coalescer.