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

query

fun ISingleQuery.query(queryGateway: EventStreamQueryGateway): Mono<DomainEventStream>

fun IListQuery.query(queryGateway: EventStreamQueryGateway): Flux<DomainEventStream>

fun IPagedQuery.query(queryGateway: EventStreamQueryGateway): Mono<PagedList<DomainEventStream>>

fun ICursorQuery.query(queryGateway: EventStreamQueryGateway): Mono<CursorPage<DomainEventStream>>

fun AggregationQuery.query(queryGateway: EventStreamQueryGateway): Flux<ObjectNode>

Executes this aggregation against persisted event-stream documents.