Cron creation operator for RxJS

README.md

rxjs-cron

A RxJS creation operator based on node-cron, because of that, it is limited to execution in Node only.

Example: https://codesandbox.io/s/rxjs-cron-hlgko

index.d.ts

import { Observable } from 'rxjs'

export declare function cron(expr: string): Observable<number>

index.js

const { Observable } = require('rxjs')
const { schedule } = require('node-cron')

function cron(expr) {
  let counter = 0

  return new Observable((subscriber) => {
    const task = schedule(expr, () => {
      subscriber.next(counter++)
    })

    task.start()

    return () => task.destroy()
  })
}

module.exports = { cron }

package.json

{
  "name": "rxjs-cron",
  "version": "0.1.0",
  "main": "index.js",
  "types": "index.d.ts",
  "peerDependencies": {
    "rxjs": ">= 6"
  },
  "dependencies": {
    "node-cron": "^2"
  }
}