StreamEventStore class abstract
Store of StreamEvents used by AggregateStore.
- Implementers
Constructors
Properties
- hashCode → int
-
The hash code for this object.
no setterinherited
- runtimeType → Type
-
A representation of the runtime type of the object.
no setterinherited
Methods
-
appendEvents(
StreamName name, Iterable< StreamEvent> events, ExpectedStreamVersion expected) → Future<AppendEventsResult> -
Append one or more events to a stream
Parameter
name
identifies stream to appendevents
to. Use parameterexpected
to indicate which stream version that was last seen. Is used to perform consistency checks based on optimistic locking. -
deleteStream(
StreamName name, ExpectedStreamVersion expected) → Future< void> -
Delete a stream. The stream can not be used again.
Parameter
name
identifies stream to truncate events from. Use parameterexpected
to indicate which stream version that was last seen. Is used to perform consistency checks based on optimistic locking -
noSuchMethod(
Invocation invocation) → dynamic -
Invoked when a nonexistent method or property is accessed.
inherited
-
readEvents(
StreamName name, StreamReadPosition start, [int count = Max]) → Future< Iterable< StreamEvent> > -
Read a fixed number of events from an existing stream
Parameter
name
identifies stream to read from. Use parameterstart
to define the position in the stream to start reading from. Usecount
to limit number of events that is read from the stream (default is Max which returns all events fromstart
). -
readEventsBackwards(
StreamName name, [int count = Max]) → Future< Iterable< StreamEvent> > -
Read a fixed number of events from an existing stream
backwards from last event.
Parameter
name
identifies stream to read from. Usecount
to limit number of events that is read from the stream (default is Max which returns all events from given stream). -
readStream(
StreamName name, StreamReadPosition start, [int count = Max]) → Stream< StreamEvent> -
Read events asynchronously as a Stream.
Parameter
name
identifies stream to read from. Use parameterstart
to define the position in the stream to start reading from. Usecount
to limit number of events that is read from the stream (default is Max which returns all events fromstart
). -
toString(
) → String -
A string representation of this object.
inherited
-
truncateStream(
StreamName name, ExpectedStreamVersion expected, StreamTruncatePosition truncate) → Future< void> -
Truncate all events on the stream upto given position
Parameter
name
identifies stream to truncate events from. Parametertruncate
is the position on stream to truncate events from. Use parameterexpected
to indicate which stream version that was last seen. Is used to perform consistency checks based on optimistic locking
Operators
-
operator ==(
Object other) → bool -
The equality operator.
inherited