Trait cqrs_es2_store::IEventDispatcher

pub trait IEventDispatcher<C: ICommand, E: IEvent> {
    fn dispatch(
        &mut self, 
        aggregate_id: &str, 
        events: &Vec<EventContext<C, E>>
    ) -> Result<(), Error>;
}

Event dispatcher are usually the query stores. It updates its query with the emitted events.

Example

For illustration only:

use cqrs_es2::{
    example_impl::{
        CustomerCommand,
        CustomerEvent,
    },
    Error,
    EventContext,
};

use cqrs_es2_store::IEventDispatcher;

pub struct CustomerEventDispatcher {
    pub name: String,
    pub email: String,
    pub latest_address: String,
};

impl IEventDispatcher<CustomerCommand, CustomerEvent>
    for CustomerEventDispatcher
{
    fn dispatch(
        &mut self,
        aggregate_id: &str,
        events: &Vec<
            EventContext<CustomerCommand, CustomerEvent>,
        >,
    ) -> Result<(), Error> {
        for event in events {
            //..
        }
        Ok(())
    }
}

Required methods

fn dispatch(
    &mut self,
    aggregate_id: &str,
    events: &Vec<EventContext<C, E>>
) -> Result<(), Error>

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

Implementors

impl<C: ICommand, E: IEvent, A: IAggregate<C, E>, Q: IQuery<C, E>> IEventDispatcher<C, E> for cqrs_es2_store::memory_store::QueryStore<C, E, A, Q>

impl<C: ICommand, E: IEvent, A: IAggregate<C, E>, Q: IQuery<C, E>> IEventDispatcher<C, E> for cqrs_es2_store::mongodb_store::QueryStore<C, E, A, Q>

impl<C: ICommand, E: IEvent, A: IAggregate<C, E>, Q: IQuery<C, E>> IEventDispatcher<C, E> for cqrs_es2_store::mysql_store::QueryStore<C, E, A, Q>

impl<C: ICommand, E: IEvent, A: IAggregate<C, E>, Q: IQuery<C, E>> IEventDispatcher<C, E> for cqrs_es2_store::postgres_store::QueryStore<C, E, A, Q>

impl<C: ICommand, E: IEvent, A: IAggregate<C, E>, Q: IQuery<C, E>> IEventDispatcher<C, E> for cqrs_es2_store::redis_store::QueryStore<C, E, A, Q>

impl<C: ICommand, E: IEvent, A: IAggregate<C, E>, Q: IQuery<C, E>> IEventDispatcher<C, E> for cqrs_es2_store::sqlite_store::QueryStore<C, E, A, Q>