Basic Observable with 3 methods

by Matthew Day

HTML

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

JavaScript

const myObservable = Rx.Observable.create((observer) => {
	setTimeout(() => {
  	observer.next('first');
  }, 2000);
  setTimeout(() => {
  	observer.next('second');
  }, 4000);
  setTimeout(() => {
  	observer.complete();
  }, 6000);
  setTimeout(() => {
  	observer.error('error');
  }, 7000);
});

myObservable.subscribe(
	(data) => { console.log(data); },
  (error) => { console.log(error); },
  () => { console.log('completed yo'); }
);