StreamEventStore class abstract

Store of StreamEvents used by AggregateStore.

Implementers

Constructors

StreamEventStore()

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 append events to. Use parameter expected 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 parameter expected 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 parameter start to define the position in the stream to start reading from. Use count to limit number of events that is read from the stream (default is Max which returns all events from start).
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. Use count 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 parameter start to define the position in the stream to start reading from. Use count to limit number of events that is read from the stream (default is Max which returns all events from start).
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. Parameter truncate is the position on stream to truncate events from. Use parameter expected 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