Struct Busstop 

pub struct Busstop { /* private fields */ }

Implementations

impl Busstop

pub fn instance() -> Arc<Self>

Returns the current instance of the bus A new instance will be created if one does not exist You can call this method as many times as you like

pub async fn register_command_middleware<C, M>(&self, middleware: M) -> &Self

where M: FnMut(DispatchedCommand, NextCommandMiddleware) -> BoxFuture<'static, DispatchedCommand> + Send + Sync + 'static,

pub async fn register_query_middleware<T, M>(&self, middleware: M) -> &Self

where M: FnMut(DispatchedQuery, NextQueryMiddleware) -> BoxFuture<'static, DispatchedQuery> + Send + Sync + 'static,

pub async fn register_command<C>( &self, handler: impl CommandHandler + 'static, ) -> &Self

Register an handler for a command

pub async fn command_has_handler<C>(&self) -> bool

Checks if a command has a register handler

pub async fn register_query<T>( &self, handler: impl QueryHandler + 'static, ) -> &Self

Register an handler for a command

pub async fn query_has_handler<Q>(&self) -> bool

Checks if a query has a registered handler

pub async fn dispatch_command<T: Send + Sync + 'static>( &self, command: T, ) -> bool

Dispatches a command event

pub async fn dispatch_query<Q: Send + Sync + 'static>( &self, query: Q, ) -> DispatchedQuery

Dispatches a query event