[−][src]Trait eventmill::store::EventSource

pub trait EventSource<E, A> where
    E: EventType,
    A: WithAggregateId, {
    type Error: Error;
    fn read<R>(
        &self, 
        aggregate_id: &AggregateIdOf<A>, 
        subscriber: &mut R
    ) -> Result<(), Self::Error>
    where
        R: ReceiveEvent<E, A>;

    fn read_from_offset<R>(
        &self, 
        aggregate_id: &AggregateIdOf<A>, 
        offset: Sequence, 
        subscriber: &mut R
    ) -> Result<(), Self::Error>
    where
        R: ReceiveEvent<E, A>;
}

Associated Types

type Error: Error

Loading content...

Required methods

fn read<R>(
    &self,
    aggregate_id: &AggregateIdOf<A>,
    subscriber: &mut R
) -> Result<(), Self::Error> where
    R: ReceiveEvent<E, A>, 

fn read_from_offset<R>(
    &self,
    aggregate_id: &AggregateIdOf<A>,
    offset: Sequence,
    subscriber: &mut R
) -> Result<(), Self::Error> where
    R: ReceiveEvent<E, A>, 

Loading content...

Implementors

impl<E, A> EventSource<E, A> for InMemoryStore<E, A> where
    E: EventType,
    A: WithAggregateId,
    AggregateIdOf<A>: Display, [src]

type Error = Error

Loading content...