Rxjs

by Vladymyr Shevchuk

HTML

<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/5.3.0/Rx.js"></script>

JavaScript

const observable = Rx.Observable.fromPromise(fetch('https://jsonplaceholder.typicode.com/posts/2'));
const observer = {
	next (...args) {
  	console.error('value', ...args);
  },
  error (...args) {
  	console.error('error', ...args);
  },
  complete (...args) {
  	console.error('complete', ...args);
  }
};

const subscription = observable.subscribe(observer);