loadStream
open override fun loadStream(aggregateId: AggregateId, headVersion: Int, tailVersion: Int): Flux<DomainEventStream>
Loads event streams for the specified aggregate within the version range. Returns copies of the stored event streams.
Return
a Flux of domain event streams
Parameters
aggregateId
the ID of the aggregate
headVersion
the starting version (inclusive)
tailVersion
the ending version (inclusive)
open override fun loadStream(aggregateId: AggregateId, headEventTime: Long, tailEventTime: Long): Flux<DomainEventStream>
Loads event streams for the specified aggregate within the event time range. Returns copies of the stored event streams.
Return
a Flux of domain event streams
Parameters
aggregateId
the ID of the aggregate
headEventTime
the starting event time (inclusive)
tailEventTime
the ending event time (inclusive)