Interface TaskQueue

ReadonlyisPaused

Readonlystats

clearPending

• clearPending(): number

  Drop queued (not running) tasks. Returns how many.

  Returns number

onIdle

• onIdle(): Promise<void>

  Resolves when fully drained.

  Returns Promise<void>

onTaskDone

• onTaskDone(
      cb: (info: TaskOutcome<unknown> & { id?: unknown }) => void,
  ): () => void

  Parameters

  • cb: (info: TaskOutcome<unknown> & { id?: unknown }) => void

  Returns () => void

pause

• pause(): void

  Returns void

push

• push<T>(
      fn: () => T | Promise<T>,
      meta?: { id?: unknown },
  ): Promise<TaskOutcome<T>>

  Type Parameters

  • T

  Parameters

  • fn: () => T | Promise<T>
  • Optionalmeta: { id?: unknown }

  Returns Promise<TaskOutcome<T>>

resume

• resume(): void

  Returns void