0.0.3 • Published 6 years ago
queue-maplimit v0.0.3
queueMapLimit
a queue concurrency limit base on Promise.
install
npm i queue-maplimit --save
//or
yarn add queue-maplimitusage
const QueueMapLimit = require("queue-maplimit");
const queue = new QueueMapLimit(limit);
queue.add(arr, iteratee); // will return a PromiseParameters:
| Name | Type | Description |
|---|---|---|
| arr | Array | A collection to iterate over. |
| limit | number | The maximum number of async operations at a time. |
| iteratee | AsyncFunction | An async function to apply to each item in arr. The iteratee should complete with the transformed item. |
| return | Promise | Promise.then(result => {}); |
example
const QueueMapLimit = require("queue-maplimit");
const queue = new QueueMapLimit(5);
queue
.add(
arr,
value =>
new Promise((resolve, reject) => {
console.log("begin", value);
setTimeout(() => {
console.log("end", value);
random(0, 10) > 9 ? reject(undefined) : resolve(value);
}, random(1, 50));
})
)
.then(result => {
console.log("task done ", result);
})
.catch(err => {
console.error("task has error ", arr);
});test
test.js