MongoSnapshotQueryService

class MongoSnapshotQueryService<S : Any>(val namedAggregate: NamedAggregate, val collection: MongoCollection<Document>, val converter: ConditionConverter<Bson> = SnapshotConditionConverter) : AbstractMongoQueryService<MaterializedSnapshot<S>> , SnapshotQueryService<S>

Constructors

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

open override val aggregateName: String

open override val collection: MongoCollection<Document>

open override val contextName: String

open override fun count(condition: Condition): Mono<Long>

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

open override fun dynamicSingle(singleQuery: ISingleQuery): Mono<DynamicDocument>

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

open override fun single(singleQuery: ISingleQuery): Mono<MaterializedSnapshot<S>>

open override fun toDynamicDocument(document: Document): DynamicDocument

open override fun toTypedResult(document: Document): MaterializedSnapshot<S>