[−][src]Trait eventmill::store::EventSource
Associated Types
Loading content...Required methods
fn read<R>(
&self,
aggregate_id: &AggregateIdOf<A>,
subscriber: &mut R
) -> Result<(), Self::Error> where
R: ReceiveEvent<E, A>,
&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>,
&self,
aggregate_id: &AggregateIdOf<A>,
offset: Sequence,
subscriber: &mut R
) -> Result<(), Self::Error> where
R: ReceiveEvent<E, A>,
Implementors
impl<E, A> EventSource<E, A> for InMemoryStore<E, A> where
E: EventType,
A: WithAggregateId,
AggregateIdOf<A>: Display,
[src]
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>,
[src]
&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>,
[src]
&self,
aggregate_id: &AggregateIdOf<A>,
offset: Sequence,
subscriber: &mut R
) -> Result<(), Self::Error> where
R: ReceiveEvent<E, A>,