Cooperative task queue. • Tasks run one‑after‑another (FIFO ordering). • Dead‑lock detection prevents nesting. • dispose() drains or cancels outstanding tasks, then rejects new ones.

Constructors

Methods

Constructors

Methods

  • Disposes the queue.

    Parameters

    • options: {
          cancel?: boolean;
      } = {}
      • Optionalcancel?: boolean

        – if true, broadcasts AbortSignal to running task. default: false (waits for tasks to finish).

    Returns Promise<void>

  • Parameters

    • type:
          | "error"
          | "disposed"
          | "enqueue"
          | "start"
          | "finish"
          | "cancel"
    • handler: ((event: QueueEvent) => any)
        • (event): any
        • Parameters

          • event: QueueEvent

          Returns any

    Returns (() => void)

      • (): void
      • Returns void

  • Parameters

    • type:
          | "error"
          | "disposed"
          | "enqueue"
          | "start"
          | "finish"
          | "cancel"
    • handler: ((event: QueueEvent) => any)
        • (event): any
        • Parameters

          • event: QueueEvent

          Returns any

    Returns (() => void)

      • (): void
      • Returns void

  • Schedule an asynchronous task.

    Type Parameters

    • T

    Parameters

    • task: ((signal: AbortSignal) => Promise<T>)

      – receives an AbortSignal so it can cancel early if desired.

        • (signal): Promise<T>
        • Parameters

          • signal: AbortSignal

          Returns Promise<T>

    Returns Promise<T>