InMemoryStateEventBus

class InMemoryStateEventBus(val sinkSupplier: (NamedAggregate) -> Sinks.Many<StateEvent<*>> = { Sinks.many().multicast().onBackpressureBuffer() }) : LocalStateEventBus, InMemoryMessageBus<StateEvent<*>, StateEventExchange<*>>

Constructors

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

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

open override val topicKind: TopicKind

open override fun close()

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