EventBatchWriter

constructor(store: EventStore, scope: CoroutineScope, capacity: Int = DEFAULT_CAPACITY, maxBatchSize: Int = DEFAULT_BATCH_SIZE, flushIntervalMs: Long = DEFAULT_FLUSH_INTERVAL_MS, onDrop: (StoredEvent, EventBatchDropReason) -> Unit = { _, _ -> }, onStored: suspend (List<StoredEvent>) -> Unit = {})