wow-core/me.ahoo.wow.event/InMemoryDomainEventBus

InMemoryDomainEventBus

class InMemoryDomainEventBus(val sinkSupplier: (NamedAggregate) -> Sinks.Many<DomainEventStream> = { Sinks.many().multicast().onBackpressureBuffer() }) : LocalDomainEventBus, InMemoryMessageBus<DomainEventStream, EventStreamExchange>

Constructors

InMemoryDomainEventBus

constructor(sinkSupplier: (NamedAggregate) -> Sinks.Many<DomainEventStream> = { Sinks.many().multicast().onBackpressureBuffer() })

Properties

open override val sinkSupplier: (NamedAggregate) -> Sinks.Many<DomainEventStream>

open override val topicKind: TopicKind

Functions

open override fun close()

open override fun DomainEventStream.createExchange(): EventStreamExchange

fun LocalDomainEventBus.metrizable(): LocalDomainEventBus

open fun receive(namedAggregates: Set<NamedAggregate>): Flux<EventStreamExchange>

open fun send(message: DomainEventStream): Mono<Void>