Struct Notifier 

pub struct Notifier { /* private fields */ }

Ordered, panic-isolated registry of CommitObservers.

Implementations

impl Notifier

pub fn new() -> Self

pub fn add_observer(&self, obs: Arc<dyn CommitObserver>) -> ObserverHandle

Registers obs. The returned ObserverHandle owns the strong Arc and unregisters on drop (RAII); the registry holds only a Weak, so the handle’s lifetime alone controls delivery and no Notifier → observer → … → Notifier strong cycle can form.

pub fn dispatch(&self, ev: &CommitEvent)

Dispatches ev to every live observer in registration order. Each on_commit is catch_unwind-isolated: a panicking observer poisons neither the caller (the committing thread) nor any other observer.

Trait Implementations

impl Clone for Notifier

fn clone(&self) -> Notifier

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for Notifier

fn default() -> Self

Returns the “default value” for a type.