promise-qu v0.0.2
Promise Qu
Promise Qu uses recursion to sequentially execute an array of Promises. The queue will wait until the current Promise is resolved before moving on to the next item.
Why use Promise Qu?
If you have an array of Promises that need to wait for the previous one to resolve before continuing.
Usage
In order to set up a basic queue you can use the following code snippet. In the example below a new queue instance is created and Promise jobs are pushed to the queue. Although there is a setTimeout
in the first job, it will wait for this to finish before moving on to job-2
and job-3
.
add(() => ...)
will push a Promise to the queue.
start()
will begin the execution of each job in the queue, this returns a Promise.
const PromiseQu = require('./src');
const isQueueStoppedByError = false;
const q = new PromiseQu(isQueueStoppedByError);
q.add('job-1', () => new Promise((resolve, reject) => {
setTimeout(() => {
reject(1);
}, 1000);
}));
q.add('job-2', () => new Promise((resolve, reject) => {
resolve(2);
}));
q.add('job-3', () => new Promise((resolve, reject) => {
resolve(3);
}));
q.start()
.then(res => console.log(res))
.catch(error => console.log('ERROR IN QUEUE', error));
Each job has the following structure:
{
"key": "job-1",
"job": "<YOUR_FUNCTION>",
"status": "<ERROR | NOT_STARTED | PENDING | SUCCESS>"
}
The flag isQueueStoppedByError
will stop the Queue from continuing to execute if it is set to true
. If false
it will continue on and push the error to an errors
array to view once everything is complete. The end response will look like:
{
"errors": [
{
"result": 1,
"key": "job-1",
"status": "ERROR"
}
],
"success": [
{
"key": "job-2",
"result": 2,
"status": "SUCCESS"
},
{
"key": "job-3",
"result": 3,
"status": "SUCCESS"
}
]
}