Tiny fifo promise queue
npm i --save p-q
Pass in a processing function that returns a promise to the constructor.
const PQ = require('p-q');
const q = PQ((msg) => {
return new Promise(function(resolve, reject) {
setTimeout(function () {
resolve(msg);
}, 1000);
});
});Then add some data to the queue:
q.add({
foo: 'hii',
bar: 'world'
})Get events back:
q.on('processed', data => {
console.log(`${JSON.stringify(data)} was processed`);
})
q.on('empty', _ => {
console.log('queue is empty');
})
q.on('error', err => {
console.error(err);
})
q.on('add', data => {
console.log('new event added', data);
})