Package-level declarations
Types
Link copied to clipboard
Functional interface for supplying Reactor schedulers for aggregate operations.
Link copied to clipboard
class DefaultAggregateSchedulerSupplier(val name: String, val parallelism: Int = Schedulers.DEFAULT_POOL_SIZE) : AggregateSchedulerSupplier, ParallelismCapable, Named
Default implementation of AggregateSchedulerSupplier that creates dedicated schedulers for each aggregate.