Struct Dispatcher 

pub struct Dispatcher { /* private fields */ }

Routes notifications to registered senders by channel name.

Implementations

impl Dispatcher

pub fn new() -> Self

pub fn register(&mut self, sender: Arc<dyn Sender>) -> &mut Self

pub fn channels(&self) -> impl Iterator<Item = &str>

pub async fn dispatch( &self, channel: &str, recipient: &str, notif: &Notification, ) -> Result<(), NotifyError>

Dispatch to the sender registered under channel.

pub async fn drain( &self, outbox: &dyn DurableOutbox, worker_id: &str, lease_secs: i64, batch: usize, retry_delay_secs: i64, ) -> Result<usize, String>

Trait Implementations

impl Clone for Dispatcher

fn clone(&self) -> Dispatcher

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for Dispatcher

fn default() -> Dispatcher

Returns the “default value” for a type.