AsyncQueueExecutor
Defined in: async/AsyncQueueExecutor.ts:22
Constructors
Constructor
new AsyncQueueExecutor(maxConcurrent?): AsyncQueueExecutor;
Defined in: async/AsyncQueueExecutor.ts:29
Parameters
| Parameter | Type | Default value |
|---|---|---|
maxConcurrent | number | 3 |
Returns
AsyncQueueExecutor
Methods
addTask()
addTask<T>(task, id?): Promise<T>;
Defined in: async/AsyncQueueExecutor.ts:33
Type Parameters
| Type Parameter |
|---|
T |
Parameters
| Parameter | Type |
|---|---|
task | () => T | Promise<T> |
id? | TaskId |
Returns
Promise<T>
clearQueue()
clearQueue(): void;
Defined in: async/AsyncQueueExecutor.ts:71
Returns
void
getQueuedCount()
getQueuedCount(): number;
Defined in: async/AsyncQueueExecutor.ts:90
Returns
number
getRunningCount()
getRunningCount(): number;
Defined in: async/AsyncQueueExecutor.ts:86
Returns
number
getStatus()
getStatus(): ExecutorStatus;
Defined in: async/AsyncQueueExecutor.ts:58
Returns
ExecutorStatus
setMaxConcurrent()
setMaxConcurrent(newMax): void;
Defined in: async/AsyncQueueExecutor.ts:66
Parameters
| Parameter | Type |
|---|---|
newMax | number |
Returns
void
waitForAll()
waitForAll(): Promise<void>;
Defined in: async/AsyncQueueExecutor.ts:81
Returns
Promise<void>