MongoEventStreamQueryService

class MongoEventStreamQueryService(val namedAggregate: NamedAggregate, collection: MongoCollection<Document>, converter: ConditionConverter<Bson> = MongoConditionConverter) : EventStreamQueryService

Constructors

constructor(namedAggregate: NamedAggregate, collection: MongoCollection<Document>, converter: ConditionConverter<Bson> = MongoConditionConverter)

open override val aggregateName: String

open override val contextName: String

open override fun dynamicList(listQuery: IListQuery): Flux<DynamicDocument>

open override fun list(listQuery: IListQuery): Flux<DomainEventStream>