Trait cqrs_es2::QueryProcessor

pub trait QueryProcessor<A: Aggregate> {
    fn dispatch(&mut self, aggregate_id: &str, events: &[EventEnvelope<A>]);
}

Each CQRS platform should have one or more QueryProcessors where it will distribute committed events, it is the responsibility of the QueryProcessor to update any interested queries.

Required methods

fn dispatch(&mut self, aggregate_id: &str, events: &[EventEnvelope<A>])

Events will be dispatched here immediately after being committed for the downstream queries to be updated.

Implementors