wow-query/me.ahoo.wow.query.event/EventStreamQueryService

EventStreamQueryService

interface EventStreamQueryService : NamedAggregateDecorator

Inheritors

NoOpEventStreamQueryService

Properties

open override val aggregateName: String

open override val contextName: String

abstract val namedAggregate: NamedAggregate

Functions

abstract fun dynamicList(listQuery: IListQuery): Flux<DynamicDocument>

isSameAggregateName

open fun isSameAggregateName(other: NamedAggregate): Boolean

isSameBoundedContext

open fun isSameBoundedContext(other: NamedBoundedContext): Boolean

abstract fun list(listQuery: IListQuery): Flux<DomainEventStream>