Package Exports

queue-maplimit

This package does not declare an exports field, so the exports above have been automatically detected and optimized by JSPM instead. If any package subpath is missing, it is recommended to post an issue to the original package (queue-maplimit) to support the "exports" field. If that is not possible, create a JSPM override to customize the exports field for this package.

Readme

queueMapLimit

a queue concurrency limit base on Promise.

install

npm i queue-maplimit --save
//or
yarn add queue-maplimit

usage

const QueueMapLimit = require("queue-maplimit");
const queue = new QueueMapLimit(limit);
queue.add(arr, iteratee); //  will return a Promise

Parameters:

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