KeyedBatchCoordinator

constructor(name: String, options: BatchOptions, laneCount: Int, keySelector: (T) -> K, writer: BatchWriter<T>)