wow-core/me.ahoo.wow.scheduler/AggregateSchedulerSupplier

AggregateSchedulerSupplier

interface AggregateSchedulerSupplier : GracefullyStoppable

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

Scheduler

Inheritors

Functions

Link copied to clipboard
open override fun close()

Closes this resource by performing a graceful shutdown.

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.

Link copied to clipboard
open fun stop()

Synchronously closes this resource with graceful shutdown.

open fun stop(timeout: Duration)

Synchronously closes this resource with graceful shutdown within a specified timeout.

Link copied to clipboard
abstract fun stopGracefully(): Mono<Void>

Asynchronously closes this resource with graceful shutdown.

Generated by Dokka
© 2026 Copyright