Class PromiseQueue

A queue that processes promises with a given concurrency and delays after each promise if desired.

Constructors

constructor

Methods

add clear close

Constructors

constructor

  • new PromiseQueue(concurrency?, delay?): PromiseQueue

  • Parameters

    • Optionalconcurrency: number
    • Optionaldelay: number

    Returns PromiseQueue

Methods

add

  • add<T>(executor): Promise<T>

  • Add a promise to the queue. It returns a promise that can be awaited.

    Type Parameters

    • T

    Parameters

    • executor: (() => Promise<T>)
        • (): Promise<T>

        • Returns Promise<T>

    Returns Promise<T>

clear

  • clear(reject): void

  • Clear the queue.

    Parameters

    • reject: boolean

    Returns void

close

  • close(): void

  • Close the queue and remove all outstanding promises (but do not reject them).

    Returns void

Settings

Member Visibility

On This Page

Constructors
Methods