wow-query/me.ahoo.wow.query/CompositeQueryObserver

CompositeQueryObserver

class CompositeQueryObserver(delegates: List<QueryObserver>) : QueryObserver

Several observers behind one: each callback reaches every delegate, a failing delegate is logged and does not stop the others, and audits are built when any delegate wants them.

Constructors

constructor(delegates: List<QueryObserver>)

Properties

audits

open override val audits: Boolean

Whether this observer wants onAudit; the gateway builds audits only when one is wanted.

Functions

onAudit

open override fun onAudit(audit: QueryAudit)

One QueryAudit per subscription, at its terminal signal.

onCancel

open override fun onCancel(namedAggregate: NamedAggregate, queryType: QueryType)

onComplete

open override fun onComplete(namedAggregate: NamedAggregate, queryType: QueryType)

onError

open override fun onError(namedAggregate: NamedAggregate, queryType: QueryType, error: Throwable)