wow-query/me.ahoo.wow.query.snapshot.filter/ListSnapshotQueryContext

ListSnapshotQueryContext

class ListSnapshotQueryContext<R : Any>(val namedAggregate: NamedAggregate, val queryType: QueryType, val attributes: MutableMap<String, Any> = ConcurrentHashMap()) : SnapshotQueryContext<ListSnapshotQueryContext<R>, IListQuery, Flux<R>>

Constructors

ListSnapshotQueryContext

constructor(namedAggregate: NamedAggregate, queryType: QueryType, attributes: MutableMap<String, Any> = ConcurrentHashMap())

Properties

open override val attributes: MutableMap<String, Any>

open override val namedAggregate: NamedAggregate

open override val queryType: QueryType

Functions

open fun <V> getAttribute(key: String): V?

open fun getQuery(): IListQuery

getRequiredResult

open fun getRequiredResult(): Flux<R>

open fun rewriteQuery(rewrite: (IListQuery) -> IListQuery): ListSnapshotQueryContext<R>

open fun rewriteResult(rewrite: (Flux<R>) -> Flux<R>): ListSnapshotQueryContext<R>

open fun setAttribute(key: String, value: Any): ListSnapshotQueryContext<R>

open fun setQuery(query: IListQuery): ListSnapshotQueryContext<R>

open fun setResult(result: Flux<R>): ListSnapshotQueryContext<R>