Method new

library/src/services/messagebus.rs:26–38

(
        command_handler: &'static CommandHandler<AtomicContextManager>,
        event_handler: &'static EventHandler<AtomicContextManager>,
    )

impl MessageBus {
    pub fn new(
        command_handler: &'static CommandHandler<AtomicContextManager>,
        event_handler: &'static EventHandler<AtomicContextManager>,
    ) -> Arc<Self> {
        Self {
            #[cfg(test)]
            book_keeper: AtomicI32::new(0),

            command_handler,
            event_handler,
        }
        .into()
    }

    pub async fn handle<C>(&self, message: C) -> ApplicationResult<ServiceResponse>
    where