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
- add(item, callback): void
-
Returns void
clear
- clear(): void
-
Returns void
decreaseParallelism
- decreaseParallelism(): void
-
Returns void
increaseParallelism
- increaseParallelism(): void
-
Returns void
invalidate
- invalidate(item): void
-
Returns void
isDone
- isDone(item): boolean
-
Returns boolean
isProcessing
- isProcessing(item): boolean
-
Returns boolean
isQueued
- isQueued(item): boolean
-
Returns boolean
stop
- stop(): void
-
Returns void
waitFor
- waitFor(item, callback): void
-
Returns void
Waits for an already started item