PoolQueue
⊕ new PoolQueue(concurrency: number): PoolQueue
Defined in index.ts:8
Parameters:
| Param | Type |
|---|---|
| concurrency | number |
Returns: PoolQueue
▸ drain(): Promise<void>
Defined in index.ts:38
Wait until the queue has no more work to complete.
Returns: Promise<void>
▸ poll(): Promise<void>
Defined in index.ts:31
Wait until the queue has at least one free worker.
Returns: Promise<void>
▸ submitT(work: function): Promise<T>
Defined in index.ts:18
Submit a task to be completed
Type parameters:
Parameters:
| Param | Type |
|---|---|
| work | function |
Returns: Promise<T>
a Promise containing the completed work. While the task is executed concurrently, the returned Promise is fulfilled serially in the order it was submitted.