Struct eventmill::dispatch::Core

pub struct Core<S> { /* fields omitted */ }

Implementations

impl<S> Core<S>

pub fn new(event_store: S) -> Self

Trait Implementations

impl<S: Debug> Debug for Core<S>

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.

impl<C, A, S> DispatchCommand<DomainCommand<C, A>, A> for Core<S> where
    A: Aggregate<<A as HandleCommand<C, A>>::Event> + AggregateType + WithAggregateId + HandleCommand<C, A> + InitializeAggregate<State = A>,
    <A as HandleCommand<C, A>>::Event: 'static + EventType,
    S: EventSource<<VersionedAggregate<A> as HandleCommand<C, VersionedAggregate<A>>>::Event, VersionedAggregate<A>> + EventSink<<VersionedAggregate<A> as HandleCommand<C, VersionedAggregate<A>>>::Event, VersionedAggregate<A>>, 

type Context = <A as HandleCommand<C, A>>::Context

type Output = VersionedAggregate<A>

type Error = CoreDispatchError<S, C, A>

fn dispatch_command(
    &self,
    DomainCommand { aggregate_id: aggregate_id, aggregate_generation: aggregate_generation, data: data }: DomainCommand<C, A>,
    context: &Self::Context
) -> Result<Self::Output, Self::Error>