Struct CommandBus 

pub struct CommandBus<E: Event> { /* private fields */ }

Available on crate feature cqrs only.

Command Bus for dispatching commands to handlers

Implementations

impl<E: Event> CommandBus<E>

pub fn new() -> Self

Create a new command bus

pub async fn register<C: Command, H: CommandHandler<C, E> + 'static>( &self, handler: H, )

Register a command handler

pub async fn dispatch<C: Command>(&self, command: C) -> CommandResult<E>

Dispatch a command

pub async fn dispatch_idempotent<C: Command>( &self, command: C, idempotency_key: String, ) -> CommandResult<E>

Dispatch a command with idempotency key

pub async fn handlers_count(&self) -> usize

Get number of registered handlers

Trait Implementations

impl<E: Event> Clone for CommandBus<E>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<E: Event> Default for CommandBus<E>

fn default() -> Self

Returns the “default value” for a type.