Demystifying RxJS, Part I: Basic Observable Test

02-demystifying-rxjs-observable-test.ts

const observable = new Observable(subscriber => {
  subscriber.next(1);
  subscriber.next(2);
  subscriber.next(3);
  setTimeout(() => {
    subscriber.next(4);
    subscriber.complete();
  }, 1000);
});

console.log("just before subscribe");
observable.subscribe(
  x => {
    console.log("got value " + x);
  },
  err => {
    console.error("something wrong occurred: " + err);
  },
  () => {
    console.log("done");
  }
);
console.log("just after subscribe");