AggregateSchedulerSupplier

Functional interface for supplying Reactor schedulers for aggregate operations.

This interface provides a way to obtain or create schedulers that are specifically dedicated to handling operations for particular aggregates. Schedulers can be shared across operations for the same aggregate or created per aggregate as needed.

The supplier pattern allows for lazy initialization and caching of schedulers, improving performance by reusing schedulers for the same aggregate operations.

See also

Inheritors

Functions

Link copied to clipboard
abstract fun getOrInitialize(namedAggregate: NamedAggregate): Scheduler

Gets an existing scheduler for the named aggregate or creates a new one if none exists.