Function createBatchProcessor
createBatchProcessor<T, R>( processor: (batch: T[]) => R[] | Promise<R[]>, options?: { batchSize?: number; parallelism?: number },): (items: T[]) => AsyncGenerator<R> Parameters
- processor: (batch: T[]) => R[] | Promise<R[]>
- options: { batchSize?: number; parallelism?: number } = {}
Returns (items: T[]) => AsyncGenerator<R>
Optimized batch processor for large datasets Uses different chunk sizes based on Node version