Class AsyncQueue<T, K, R> Abstract
Properties
hooks
hooks
: { added
: SyncHook<[T], void, UnsetAdditionalOptions>; beforeAdd
: AsyncSeriesHook<[T], UnsetAdditionalOptions>; beforeStart
: AsyncSeriesHook<[T], UnsetAdditionalOptions>; result
: SyncHook<[T, Error, R], void, UnsetAdditionalOptions>; started
: SyncHook<[T], void, UnsetAdditionalOptions> }Methods
add
Parameters
Returns void
clear
Returns void
decreaseParallelism
- decreaseParallelism(): void
Returns void
increaseParallelism
- increaseParallelism(): void
Returns void
invalidate
- invalidate(item: T): void
Parameters
Returns void
isDone
Parameters
Returns boolean
isProcessing
- isProcessing(item: T): boolean
Parameters
Returns boolean
isQueued
- isQueued(item: T): boolean
Parameters
Returns boolean
stop
Returns void
waitFor
Parameters
Returns void
Waits for an already started item