Struct eventmill::inmemory_store::InMemoryStore

pub struct InMemoryStore<E, A> where
    A: WithAggregateId,  { /* fields omitted */ }

Implementations

impl<E, A> InMemoryStore<E, A> where
    A: WithAggregateId,
    AggregateIdOf<A>: Display, 

pub fn new() -> Self

pub fn with_events(events: impl IntoIterator<Item = DomainEvent<E, A>>) -> Self

Trait Implementations

impl<E: Debug, A: Debug> Debug for InMemoryStore<E, A> where
    A: WithAggregateId, 

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

Formats the value using the given formatter.

impl<E, A> Default for InMemoryStore<E, A> where
    A: WithAggregateId, 

fn default() -> Self

Returns the "default value" for a type.

impl<E, A> EventSink<E, A> for InMemoryStore<E, A> where
    E: EventType,
    A: WithAggregateId,
    AggregateIdOf<A>: Display, 

type Error = Error

fn append(&self, event: DomainEvent<E, A>) -> Result<(), Self::Error>

fn append_batch(
    &self,
    events: impl IntoIterator<Item = DomainEvent<E, A>>
) -> Result<(), Self::Error>

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

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>,