load
abstract fun load(aggregateId: AggregateId, headVersion: Int = DEFAULT_HEAD_VERSION, tailVersion: Int = Int.MAX_VALUE): Flux<DomainEventStream>
根据聚合ID加载事件流.
val offset=headVersion-1;
val limit=tailVersion-headVersion+1;
Content copied to clipboard
headVersion~tailVersion
Return
事件流
Parameters
aggregateId
聚合ID
headVersion
事件流的第一个事件版本号,当 headVersion
=H 时,即从事件版本号 H (包括)开始加载事件流。
tailVersion
事件流的最后一个版本号,包括.