Struct CommandBus 

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

Command Bus for dispatching commands to handlers

Implementations

impl<E> CommandBus<E>

where E: Event,

pub fn new() -> CommandBus<E>

Create a new command bus

pub async fn register<C, H>(&self, handler: H)

where C: Command, H: CommandHandler<C, E> + 'static,

Register a command handler

pub async fn dispatch<C>(&self, command: C) -> Result<Vec<E>, CommandError>

where C: Command,

Dispatch a command

pub async fn dispatch_idempotent<C>( &self, command: C, idempotency_key: String, ) -> Result<Vec<E>, CommandError>

where C: Command,

Dispatch a command with idempotency key

pub async fn handlers_count(&self) -> usize

Get number of registered handlers

Trait Implementations

impl<E> Clone for CommandBus<E>

where E: Event,

fn clone(&self) -> CommandBus<E>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<E> Default for CommandBus<E>

where E: Event,

fn default() -> CommandBus<E>

Returns the “default value” for a type.