InMemoryStateEventBus
constructor(sinkSupplier: (NamedAggregate) -> Sinks.Many<StateEvent<*>> = {
Sinks.many().multicast().onBackpressureBuffer()
})
Parameters
sinkSupplier
Supplier for creating sinks for each named aggregate (default: multicast sink with backpressure buffer).