Struct SubscriberRegistry 

pub struct SubscriberRegistry<Event: Clone + Send + Sync + 'static> { /* private fields */ }

A registry that holds multiple closure-based subscribers for the same event type.

Dispatch an event to all registered subscribers in registration order.

For EventHandler-based subscriptions prefer GenericEventSubscriber.

Implementations

impl<Event: Clone + Send + Sync + 'static> SubscriberRegistry<Event>

pub fn new() -> Self

pub fn register<F, Fut>(&mut self, handler: F)

where F: Fn(Event) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<(), EventError>> + Send + 'static,

Register a closure subscriber.

pub async fn dispatch_all(&self, event: Event) -> Vec<EventError>

Dispatch to all registered subscribers, collecting errors.

pub fn subscriber_count(&self) -> usize

Trait Implementations

impl<Event: Clone + Send + Sync + 'static> Default for SubscriberRegistry<Event>

fn default() -> Self

Returns the “default value” for a type.