MetricStateEventBus

Constructors

constructor(delegate: T)

override val delegate: T

open override val name: String

open override val topicKind: TopicKind

open override fun close()

open override fun receive(namedAggregates: Set<NamedAggregate>): Flux<StateEventExchange<*>>

open override fun send(message: StateEvent<*>): Mono<Void>

fun <M> Flux<M>.tagSource(): Flux<M>

fun <M> Mono<M>.tagSource(): Mono<M>