Variable asyncIterUtilsConst

Type declaration

• mapConcurrent:function

  • mapConcurrent<T, R>(
        iterator: AsyncIterable<T>,
        mapper: (item: T) => R | Promise<R>,
        concurrency?: number,
    ): AsyncGenerator<R>

    Map over async iterator with concurrency control (Node 20+)

    Type Parameters

    • T
    • R

    Parameters

    • iterator: AsyncIterable<T>
    • mapper: (item: T) => R | Promise<R>
    • concurrency: number = 4

    Returns AsyncGenerator<R>

• batch:function

  • batch<T>(iterator: AsyncIterable<T>, size?: number): AsyncGenerator<T[]>

    Batch items from async iterator

    Type Parameters

    • T

    Parameters

    • iterator: AsyncIterable<T>
    • size: number = 1000

    Returns AsyncGenerator<T[]>