Struct CollectingHandler 

pub struct CollectingHandler<E: DomainEvent> { /* private fields */ }

A handler that collects events for testing

Implementations

impl<E: DomainEvent> CollectingHandler<E>

pub fn new() -> Self

Create a new collecting handler

pub async fn events(&self) -> Vec<EventEnvelope<E>>

Get all collected events

pub async fn clear(&self)

Clear collected events

pub async fn count(&self) -> usize

Get event count

Trait Implementations

impl<E: Default + DomainEvent> Default for CollectingHandler<E>

fn default() -> Self

Returns the “default value” for a type.

impl<E: DomainEvent> EventHandler<E> for CollectingHandler<E>

fn handle<'life0, 'async_trait>( &'life0 self, envelope: EventEnvelope<E>, ) -> Pin<Box<dyn Future<Output = Result<(), EventError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handle a domain event

fn event_types(&self) -> Vec<&'static str>

Event types this handler is interested in

fn name(&self) -> &'static str

Handler name for logging and debugging

fn should_retry(&self) -> bool

Whether this handler should be retried on failure

fn max_retries(&self) -> u32

Maximum retry attempts