RxJs Medium Gists

medium-rxjs-observable.js

import { Observable } from 'rxjs';

const observable = new Observable(subscriber => {
  
  subscriber.next("First State / Data of Observable"); // Notifiying first state
  subscriber.next("Second State / Data of Observable"); // Notifiying second state
  subscriber.next("Third State / Data of Observable"); // Notifiying third state
  
  // Just waiting 5 seconds
  
  setTimeout(() => {
    subscriber.next("Fourth State / Data of Observable"); // Notifiying fourth state
    subscriber.complete(); // Notifiying that the is no more data to notify
  }, 5000);
  
});