Struct event_driven_library::prelude::MessageBus

pub struct MessageBus<R, E>where
    R: ApplicationResponse,
    E: ApplicationError + Into<BaseError> + From<BaseError>,{ /* private fields */ }

Implementations

impl<R, E> MessageBus<R, E>where R: ApplicationResponse, E: ApplicationError + Into<BaseError> + From<BaseError>,

pub fn new( command_handler: &'static HashMap<TypeId, fn(_: Box<dyn Any + Send + Sync, Global>, _: Arc<RwLock<ContextManager>, Global>) -> Pin<Box<dyn Future<Output = Result<R, E>> + Send, Global>>, RandomState>, event_handler: &'static HashMap<String, Vec<Box<dyn Fn(Box<dyn Message, Global>, Arc<RwLock<ContextManager>, Global>) -> Pin<Box<dyn Future<Output = Result<R, E>> + Send, Global>> + Send + Sync, Global>, Global>, RandomState> ) -> Arc<MessageBus<R, E>, Global>

pub async fn handle<C>(&self, message: C) -> impl Future<Output = Result<R, E>>where C: Command,