async-function-queue

Simple async function queue.

Install

$ npm install async-function-queue --save

Use

var Queue = require('async-function-queue');
 
var concurrency = 2;
 
// create a queue, defining concurrency
var queue = Queue(concurrency);
 
// push a function that accepts a callback
// as sole argument
queue.push(function(cb) {
  setTimeout(cb, 1000);
});

Events

// Some emitted events
 
queue.on('entry', function() {
  console.log('starting to execute function');
});
 
queue.on('exit', function() {
  console.log('finished executing function');
});
 
queue.on('drain', function() {
  console.log('queue has drained');
});
 

License

ISC