Options
All
  • Public
  • Public/Protected
  • All
Menu

Serialize tasks running on the same stream. Ensure that a task is run with the currently available running state - either from memory or from state store. This makes a task code simpler.

Hierarchy

  • ExecutionQueue

Index

Constructors

Properties

Methods

Constructors

constructor

  • new ExecutionQueue(concurrencyLimit: number, logger: DiagnosticsLogger): ExecutionQueue

Properties

Readonly semaphore

semaphore: Semaphore

Readonly tasks

Methods

close

  • close(): Promise<void>

forStream

onIdle

  • onIdle(): Promise<void>

pause

  • pause(): void