Struct CommandEvents 

pub struct CommandEvents<T: ICommandInfo> { /* private fields */ }

Collect and query command lifecycle events.

Implementations

impl<T: ICommandInfo + 'static> CommandEvents<T>

pub fn new(mediator: Arc<CommandMediator<T>>) -> Self

Create a new CommandEvents backed by a CommandMediator.

pub async fn start(&self)

Start listening for events from the CommandMediator.

pub async fn get(&self) -> MutexGuard<'_, Vec<T::Event>>

Lock and return the collected events.

pub async fn count(&self) -> CommandEventCounts

Count events by EventKind.

Trait Implementations

impl<T: ICommandInfo + 'static> FromServices for CommandEvents<T>

type Error = ResolveError

Error type returned by FromServices::from_services.

fn from_services( services: &ServiceProvider, ) -> Result<Self, Report<Self::Error>>

Create an instance by resolving dependencies from the ServiceProvider.