cqrs_eventsourcing/
handler.rs

1use async_trait::async_trait;
2
3use crate::{Aggregate, DomainEvent, FormatedEvent};
4
5pub type Handlers<A, E> = Vec<Box<dyn Handler<A, E> + Send>>;
6
7#[async_trait]
8pub trait Handler<A, E>
9where
10    A: Aggregate,
11    E: DomainEvent<A>,
12{
13    async fn handle(&self, events: &Vec<FormatedEvent<A, E>>);
14}