InMemoryStateEventBus

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

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()

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

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