RxJS Example

by jsmuster

HTML

<script src="https://unpkg.com/rxjs@%5E7/dist/bundles/rxjs.umd.min.js"></script>

JavaScript

let obs = rxjs.Observable.create((subscriber) => {
  subscriber.next(1);
  subscriber.next(2);
  subscriber.next(3);
  subscriber.complete();
});

obs.subscribe((value) => {
  console.log(value);
});