jaeb 0.3.12

simple snapshot-driven event bus
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

use core::future::Future;
use core::pin::Pin;

use crate::{EventBus, EventBusError, Subscription};

/// Trait implemented by macro-generated handler registrar types.
pub trait HandlerRegistrar: Send + Sync + 'static {
    /// Subscribe this handler to the provided event bus.
    fn register<'a>(&self, bus: &'a EventBus) -> Pin<Box<dyn Future<Output = Result<Subscription, EventBusError>> + Send + 'a>>;
}

inventory::collect!(&'static dyn HandlerRegistrar);

/// Registers all handlers discovered via inventory auto-discovery.
pub async fn register_all(bus: &EventBus) -> Result<(), EventBusError> {
    for registrar in inventory::iter::<&'static dyn HandlerRegistrar>.into_iter() {
        let _ = registrar.register(bus).await?;
    }

    Ok(())
}

/// Re-exports used by macro-generated code.
#[doc(hidden)]
pub mod _private {
    pub use inventory;
}