wow-core/me.ahoo.wow.metrics/MetricDistributedStateEventBus

MetricDistributedStateEventBus

class MetricDistributedStateEventBus(delegate: DistributedStateEventBus) : MetricStateEventBus<DistributedStateEventBus> , DistributedStateEventBus

Constructors

Link copied to clipboard
constructor(delegate: DistributedStateEventBus)

Properties

Link copied to clipboard
Link copied to clipboard
open override val name: String
Link copied to clipboard
open override val topicKind: TopicKind

Functions

Link copied to clipboard
open override fun close()
Link copied to clipboard
Link copied to clipboard
abstract fun receive(namedAggregates: Set<NamedAggregate>): Flux<StateEventExchange<*>>
Link copied to clipboard
abstract fun send(message: StateEvent<*>): Mono<Void>
Link copied to clipboard
fun <M> Flux<M>.tagSource(): Flux<M>
fun <M> Mono<M>.tagSource(): Mono<M>