wow-query/me.ahoo.wow.query.event.filter/DefaultEventStreamQueryHandler

DefaultEventStreamQueryHandler

class DefaultEventStreamQueryHandler(chain: FilterChain<QueryContext<*, *>>, errorHandler: ErrorHandler<QueryContext<*, *>> = LogErrorHandler()) : AbstractQueryHandler<DomainEventStream> , EventStreamQueryHandler

Constructors

Link copied to clipboard
constructor(chain: FilterChain<QueryContext<*, *>>, errorHandler: ErrorHandler<QueryContext<*, *>> = LogErrorHandler())

Functions

Link copied to clipboard
abstract fun count(namedAggregate: NamedAggregate, condition: Condition): Mono<Long>
Link copied to clipboard
abstract fun dynamicList(namedAggregate: NamedAggregate, query: IListQuery): Flux<DynamicDocument>
Link copied to clipboard
abstract fun dynamicPaged(namedAggregate: NamedAggregate, pagedQuery: IPagedQuery): Mono<PagedList<DynamicDocument>>
Link copied to clipboard
abstract fun dynamicSingle(namedAggregate: NamedAggregate, singleQuery: ISingleQuery): Mono<DynamicDocument>
Link copied to clipboard
abstract fun handle(context: QueryContext<*, *>): Mono<Void>
Link copied to clipboard
abstract fun list(namedAggregate: NamedAggregate, listQuery: IListQuery): Flux<DomainEventStream>
Link copied to clipboard
abstract fun paged(namedAggregate: NamedAggregate, pagedQuery: IPagedQuery): Mono<PagedList<DomainEventStream>>
Link copied to clipboard
abstract fun single(namedAggregate: NamedAggregate, singleQuery: ISingleQuery): Mono<DomainEventStream>