Background Forever Concurrent

A simple utility to run concurrent background tasks forever.

Quick Start

const { BackgroundForeverConcurrent } = require('background-forever-concurrent');

const bfConcurrent = new BackgroundForeverConcurrent(4, () => {
    return new Promise<void>((resolve, reject) => {
        console.log('hello world!');
        setTimeout(() => {
            resolve();
        }, 1000);
    });
});

bfConcurrent.start();

setTimeout(() => {
    bf.stop().then(() => {
        console.log('stopped successfully!');
    }).catch((e) => {
        console.error('error occurred while stopping the concurrent functions', e);
    });
}, 5000);

Events

BackgroundForeverConcurrent emits a number of events which you can subscribe to. The events are the same as in the BackgroundForever library, except the event values are wrapped in an object along with a property which indicating which concurrent function emitted the event.

Before Run

beforeRun fires each time before calling your function. Value is like:

{
    runCount: 1, // run count, starting at one
    which: 0 // which concurrent task, zero-based
}

Run Success

runSuccess fires after your function successfully resolves its returned promise. Value is like:

{
    result: value, // background function return value
    which: 0 // which concurrent task, zero-based
}

Run Error

runError fires if your function throws an error. The value in the event is like:

{
    error: 'some error', // error emitted or promise rejection message
    which: 0 // which concurrent task, zero-based
}