Struct EventBuffer 

pub struct EventBuffer { /* private fields */ }

Thread-safe event buffer for deferring event emissions during transactions.

Repositories push events into this buffer instead of sending them directly to the EventHub. On commit(), the UoW drains the buffer and sends all events. On rollback(), the buffer is discarded. This prevents the UI from seeing phantom state from failed transactions.

This is the Rust equivalent of SignalBuffer in the C++/Qt target.

Implementations

impl EventBuffer

pub fn new() -> Self

pub fn begin_buffering(&mut self)

Start buffering. Clears any stale events from a previous cycle.

pub fn push(&mut self, event: Event)

Queue an event for deferred delivery.

If buffering is not active, the event is silently dropped. (Callers should only push during an active transaction.)

pub fn flush(&mut self) -> Vec<Event>

Drain all pending events and stop buffering. The caller is responsible for sending them to the EventHub.

pub fn discard(&mut self)

Discard all pending events and stop buffering.

pub fn is_buffering(&self) -> bool

Trait Implementations

impl Default for EventBuffer

fn default() -> Self

Returns the “default value” for a type.