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)