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