Class Limiter<T>

A helper to queue N promises and run them all with a max degree of parallelism. The helper ensures that at any time no more than M promises are running at the same time.

Type Parameters

T

Index

Constructors

Accessors

Methods

dispose onFinished queue

Constructors

constructor

new Limiter<T>(maxDegreeOfParalellism: number): Limiter<T>
Type Parameters
- T
Parameters
- maxDegreeOfParalellism: number
Returns Limiter<T>
- Defined in src/common/async.ts:473

Accessors

size

get size(): number
Returns number
- Defined in src/common/async.ts:481

Methods

dispose

dispose(): void
Returns void
- Defined in src/common/async.ts:521

onFinished

onFinished(callback: (...args: unknown[]) => unknown): void
Parameters
- callback: (...args: unknown[]) => unknown
Returns void
- Defined in src/common/async.ts:477

queue

queue(factory: ITask<Promise<T>>): Promise<T>
Parameters
- factory: ITask<Promise<T>>
Returns Promise<T>
- Defined in src/common/async.ts:485