BatchCoordinator

Coordinates bounded, non-blocking admission and graceful shutdown for storage-independent reactive batches.

Each internal batch lane owns buffering and serial writes. The internal admission controller owns the global capacity shared by lanes, and the result dispatcher isolates per-item subscriber callbacks.

Constructors

Link copied to clipboard
constructor(name: String, options: BatchOptions, writer: BatchWriter<T>, metrics: WowMetrics = WowMetrics.NONE)

Properties

Link copied to clipboard
Link copied to clipboard

Functions

Link copied to clipboard
open override fun close()

Closes this resource by performing a graceful shutdown with a 30-second timeout.

fun close(timeout: Duration)
Link copied to clipboard
open override fun stopGracefully(): Mono<Void>

Asynchronously closes this resource with graceful shutdown.

Link copied to clipboard
fun submit(item: T): Mono<Void>
fun submit(itemFactory: () -> T): Mono<Void>