Options
All
  • Public
  • Public/Protected
  • All
Menu

Class PromiseQueue<WorkItem, Result>

This queue ensures a max concurrency and that, on error, all concurrent work is completed before the error is propagated. New work can be added as needed.

Type parameters

  • WorkItem

  • Result

Hierarchy

  • PromiseQueue

Index

Constructors

Properties

Accessors

Methods

Constructors

constructor

  • new PromiseQueue(concurrency: number, processor: function): PromiseQueue

Properties

Private draining

draining: Promise<void> | undefined

Private jobId

jobId: number

Private promiseProcessor

promiseProcessor: function

Type declaration

    • (item: WorkItem): Promise<Result>

    • Parameters

      • item: WorkItem

      Returns Promise<Result>

Private queue

queue: AsyncQueue<PendingWork<WorkItem, Result>>

Private queueId

queueId: number

Accessors

activeJobCount

  • get activeJobCount(): number

concurrency

  • get concurrency(): number

Methods

debug

  • debug(message: string): void

drain

  • drain(): Promise<void>

enqueue

  • enqueue(item: WorkItem): Promise<Result>

Private processWork

  • processWork(work: PendingWork<WorkItem, Result>, callback: function): void

restart

  • restart(): void

Generated using TypeDoc