load
abstract fun load(aggregateId: AggregateId, headVersion: Int = DEFAULT_HEAD_VERSION, tailVersion: Int = DEFAULT_TAIL_VERSION): Flux<DomainEventStream>
Loads domain event streams for the specified aggregate within the given version range. The range is inclusive: headVersion, tailVersion.
Return
a Flux of domain event streams
Parameters
aggregateId
the ID of the aggregate to load events for
headVersion
the starting version (inclusive, default: 1)
tailVersion
the ending version (inclusive, default: Int.MAX_VALUE - 1)
abstract fun load(aggregateId: AggregateId, headEventTime: Long, tailEventTime: Long): Flux<DomainEventStream>
Loads domain event streams for the specified aggregate within the given event time range. The range is inclusive: headEventTime, tailEventTime.
Return
a Flux of domain event streams
Parameters
aggregateId
the ID of the aggregate to load events for
headEventTime
the starting event time (inclusive)
tailEventTime
the ending event time (inclusive)