0.0.5 • Published 8 years ago
cogsworth-scheduler v0.0.5
cogsworth-scheduler
The Scheduler
is the backbone of cogsworth. It's responsible for taking in schedules, executing schedule triggers, piping schedule trigger events down to subscribers, and tidying up expired schedules.
usage
var Scheduler = require('cogsworth-scheduler')
var scheduler = new Scheduler()
scheduler.start()
.then(triggerStream => { // triggerStream instanceof Observable
return triggerStream.forEach(({ id, event: { date } }) => {
console.log(`schedule ${id} fired at ${date}`)
})
})