worker-queue

Small sample queuing system implementation.

Install

$ npm install worker-queue

Usage

const queue = require('worker-queue')
 
const worker = (data, done) => {
  // handle data
  done(null, data)
}
 
const notifier = () => console.log('all jobs completed')
const options = { concurrency: 1, notifier }
 
const client = queue(worker, options)
 
client.push({ test: true }, (err, result) => {
  // do something
})

License

MIT