Struct InMemorySink 

pub struct InMemorySink {
    pub records: Arc<Mutex<Vec<NotificationRecord>>>,
    /* private fields */
}

Test-only sink: stores every emitted record in an Arc<Mutex<Vec<_>>> so the test can drain + assert without parsing log output. Optionally returns a stubbed failure to exercise the dbus_failure_logged path.

Fields

records: Arc<Mutex<Vec<NotificationRecord>>>

Records accumulated across every Self::show call. Tests lock() + clone() to snapshot.

Implementations

impl InMemorySink

pub fn new() -> Self

Construct an empty in-memory sink with no failure injection.

pub fn with_failure(message: impl Into<String>) -> Self

Construct a sink that fails every show() with the given message. Used by notification_dispatcher_handles_sink_failure.

pub fn snapshot(&self) -> Vec<NotificationRecord>

Snapshot of the records vector. Convenient for assertions that don’t want to hold the lock.

Trait Implementations

impl Clone for InMemorySink

fn clone(&self) -> InMemorySink

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InMemorySink

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for InMemorySink

fn default() -> InMemorySink

Returns the “default value” for a type.

impl NotificationSink for InMemorySink

fn show<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, summary: &'life1 str, body: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), NotificationError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Emit a single notification. summary is the title; body is already-sanitized HTML-escaped text suitable for daemons that interpret a subset of HTML markup (KDE, GNOME).