load
open override fun load(aggregateId: AggregateId, headVersion: Int, tailVersion: Int): 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
事件流的最后一个版本号，包括.
open override fun load(aggregateId: AggregateId, headEventTime: Long, tailEventTime: Long): Flux<DomainEventStream>
根据聚合ID和事件发生时间戳加载事件流.