const promiseAllLimit = require('promise-all-limit');
 
function job_reject_b(name) {
    const text = `job ${name}`
    console.log('started', text)
    return new Promise(function (resolve, reject) {
        setTimeout(() => {
            if (name === 'b') {
                return reject(new Error('b reject'));
            }
            console.log('       ', text, 'finished')
            resolve(text);
        }, 100)
    })
}
 
async function test() {
    try {
        const jobs = ['a', 'b', 'c', 'd', 'e'];
        const concurrency = 3;
        const results = await promiseAllLimit(jobs, concurrency, function (item) {
            return job_reject_b(item);
        });
        console.log('results:', results)
    } catch (e) {
        console.log('---> err:', e.message);
    }
}
 
test();