Struct NotificationRouter 

pub struct NotificationRouter { /* private fields */ }

Dispatches a single SinkEvent to multiple NotificationSinks.

Sinks are called sequentially (no async / thread overhead). For async fan-out combine with crate::fan_pattern::FanExecutor.

Implementations

impl NotificationRouter

pub fn new() -> Self

Create an empty router.

pub fn add_sink(&mut self, sink: Box<dyn NotificationSink>)

Add a sink.

pub fn sink_count(&self) -> usize

Number of registered sinks.

pub fn dispatch(&self, event: &SinkEvent) -> RouterSummary

Dispatch event to all registered sinks and return a RouterSummary.

pub fn sink_names(&self) -> Vec<&str>

Names of all registered sinks.

Trait Implementations

impl Debug for NotificationRouter

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

Formats the value using the given formatter.

impl Default for NotificationRouter

fn default() -> NotificationRouter

Returns the “default value” for a type.