@ntlab/work

Nodejs queue and promise based work queue

Queue Processing (queue.js)

Provide a queue mechanism.

const { Queue } = require('@ntlab/work');

const queues = ['One', 'Two', 'Three'];
const q = new Queue(queues, seq => {
    console.log(seq);
    q.next();
});
q.once('done', () => {
    ...
});

Promise Based Work Queue (work.js)

Provide promise queue mechanism for easy chaining. It accepts a function as its worker. Its also accepts an array with signature of [[string,] function, function]. If the first element is a string, it is considered as step name and can be used to reference the result later, otherwise the first element would be the worker and the second would be a state function and must be evaluated to true for worker to be executed.

const { Work } = require('@ntlab/work');
Work.works([
    ['step-1', w => new Promise((resolve, reject) => {
        console.log('First work');
        resolve(false);
    })],
    ['step-2', w => new Promise((resolve, reject) => {
        console.log('This will be skipped');
        resolve();
    }), w => w.getRes(0)/* can be referenced using w.getRes('step-1') */],
    ['step-3', w => new Promise((resolve, reject) => {
        console.log('It\'s done');
        resolve();
    })],
])
.then(res => {
    ...
})
.catch(err => {
    ...
});