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

SingleSnapshotQueryContext

class SingleSnapshotQueryContext<R : Any>(val namedAggregate: NamedAggregate, val queryType: QueryType, val attributes: MutableMap<String, Any> = ConcurrentHashMap()) : SnapshotQueryContext<SingleSnapshotQueryContext<R>, ISingleQuery, Mono<R>>

Constructors

SingleSnapshotQueryContext

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(): ISingleQuery

getRequiredResult

open fun getRequiredResult(): Mono<R>

open fun rewriteQuery(rewrite: (ISingleQuery) -> ISingleQuery): SingleSnapshotQueryContext<R>

open fun rewriteResult(rewrite: (Mono<R>) -> Mono<R>): SingleSnapshotQueryContext<R>

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

open fun setQuery(query: ISingleQuery): SingleSnapshotQueryContext<R>

open fun setResult(result: Mono<R>): SingleSnapshotQueryContext<R>