throttleq

Limit the number of promises that can be simultaneously in flight.

Usage

var q = require('q');
var throttle = require('throttleq');
 
var promiseFactory = function() {
  ...
  return promise;
};
 
/* Takes promise returning function and number of simultaneously running
 * promises.
 */
var promiseThrottle = throttle(promiseFactory, 4);
 
q.all([
  promiseThrottle(args),
  ...
  promiseThrottle(args)
]);