- promisePool<T>(options): {
getCuncurrency: (() => number);
getCurrent: (() => number);
run: (() => Promise<void>);
} Parameters
- options: {
concurrency?: number;
errorHandler?: ((error, item) => void | Promise<void>);
handler: ((item) => void | Promise<void>);
items: Iterable<T> | AsyncIterable<T>;
}Optional concurrency?: number
Optional errorHandler?: ((error, item) => void | Promise<void>)
- (error, item): void | Promise<void>
Returns void | Promise<void>
handler: ((item) => void | Promise<void>)
- (item): void | Promise<void>
Returns void | Promise<void>
items: Iterable<T> | AsyncIterable<T>
Returns {
getCuncurrency: (() => number);
getCurrent: (() => number);
run: (() => Promise<void>);
}
getCuncurrency: (() => number)
getCurrent: (() => number)
run: (() => Promise<void>)
- (): Promise<void>
Returns Promise<void>
Maximum amount of promises running at the same time.