RxJS Tutorial - Unsubscribe

rxjs-unsubscribe.js

const { interval } = require('rxjs')
const { throttleTime } = require('rxjs/operators');

// emit value every 500 millisecond (0.5 second)
const myObserver = interval(500);

const myThrottledObserver = myObserver.pipe(throttleTime(1000));

const myDisposable = myThrottledObserver.subscribe(val => console.log(val));

// unsubscribe after 10 seconds
setTimeout(() => {
  myDisposable.unsubscribe();
}, 10000);