Reactive Extentions - Observables

rx-interval.job.js

const rx = require('rx');

let subscription = rx.Observable
  .interval(60000)
  .doAction(counter => {
    console.log(counter + ' Hello from a RxJs 1min interval job!');
  })
  .subscribe();

this.onCleanup = () => subscription.dispose();