InMemoryEventStore

InMemoryEventStore .

Author

ahoo wang

Constructors

Link copied to clipboard
constructor()

Functions

Link copied to clipboard
open override fun append(eventStream: DomainEventStream): Mono<Void>

Append event stream to EventStore. Ensure transaction consistency.

Link copied to clipboard
open override fun appendStream(eventStream: DomainEventStream): Mono<Void>
Link copied to clipboard
open override fun load(aggregateId: AggregateId, headVersion: Int, tailVersion: Int): Flux<DomainEventStream>

根据聚合ID加载事件流.

Link copied to clipboard
open override fun loadStream(aggregateId: AggregateId, headVersion: Int, tailVersion: Int): Flux<DomainEventStream>
Link copied to clipboard