• Type Parameters

    • T

    Parameters

    • options: {
          concurrency?: number;
          errorHandler?: ((error, item) => void | Promise<void>);
          handler: ((item) => void | Promise<void>);
          items: Iterable<T> | AsyncIterable<T>;
      }
      • Optional concurrency?: number

        Maximum amount of promises running at the same time.

        Default

        10
        
      • Optional errorHandler?: ((error, item) => void | Promise<void>)

        Will trigger each time an error occurs.

          • (error, item): void | Promise<void>
          • Parameters

            • error: Error
            • item: T

            Returns void | Promise<void>

      • handler: ((item) => void | Promise<void>)

        Handler function for each item.

          • (item): void | Promise<void>
          • Parameters

            • item: T

            Returns void | Promise<void>

      • items: Iterable<T> | AsyncIterable<T>

        Iterable of items.

    Returns {
        getCuncurrency: (() => number);
        getCurrent: (() => number);
        run: (() => Promise<void>);
    }

    • getCuncurrency: (() => number)
        • (): number
        • Returns number

    • getCurrent: (() => number)

      Current amount of running promises.

        • (): number
        • Returns number

    • run: (() => Promise<void>)
        • (): Promise<void>
        • Returns Promise<void>