Soldier
Reactive Soldier is an rxjs library for scheduling task to run on present or in an interval of time.
Instalation
npm install @miguelramos/soldier
Usage
import { Pipeline, Job, JobAttributes } from '@miguelramos/soldier';
const pipeline = new Pipeline();
pipeline.queue('TASK', (job: Job, _attrs?: JobAttributes) => {
// perform your task
});
pipeline.dispatch('TASK', {
repeatInterval: 1000
}).subscribe();