load

open override fun load(aggregateId: AggregateId, headVersion: Int, tailVersion: Int): Flux<DomainEventStream>

根据聚合ID加载事件流.

val offset=headVersion-1;
val limit=tailVersion-headVersion+1;

headVersion~tailVersion

Return

事件流

Parameters

aggregateId

聚合ID

headVersion

事件流的第一个事件版本号,当 headVersion=H 时,即从事件版本号 H (包括)开始加载事件流。

tailVersion

事件流的最后一个版本号,包括.