RxJS - Observables, Observer & Subscription

Understand what Observables, Operators and Subscriptions are

by Shital Agarwal

HTML

<script src="https://unpkg.com/@reactivex/[email protected]/dist/global/Rx.js"></script>

JavaScript

console.log("--------------------------Observable-------------------------------")
const observable = Rx.Observable.create(observer => {
  console.log('Text inside an observable');
  observer.next('Hello world!');
  observer.complete();
});

console.log('Before subscribing an Observable');

//observable.subscribe((message) => console.log("After next ->", message));

console.log("--------------------------Promise-------------------------------")

const greetingPoster = new Promise((resolve, reject) => {
  console.log('Text inside promise');
  resolve('Hello world!');
});

console.log('Before calling then method on Promise');

//greetingPoster.then(message => console.log(message));