BatchCoordinator

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

Each BatchLane owns buffering and serial writes. BatchAdmission owns the global capacity shared by lanes, and BatchResultDispatcher isolates per-item subscriber callbacks.

Constructors

constructor(name: String, options: BatchOptions, writer: BatchWriter<T>)

open override fun close()

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

fun close(timeout: Duration)

open fun stop()

Synchronously stops this resource with a 30-second timeout.

open fun stop(timeout: Duration)

Synchronously stops this resource within the specified timeout.

open override fun stopGracefully(): Mono<Void>

Asynchronously closes this resource with graceful shutdown.

fun submit(item: T): Mono<Void>

fun submit(itemFactory: () -> T): Mono<Void>