JSFiddle - React, Tailwind, and code Playground
by pointzerotwo
HTML
<script src="https://npmcdn.com/@reactivex/[email protected]/dist/global/Rx.umd.js"></script>
JavaScript
var loggedIn$ = Rx.Observable.create((observer) => {
observer.next(false);
});
var baseline = loggedIn$.map( b => {return Promise.resolve(b);} ); // observable of promises
var preFlat = loggedIn$.flatMap( b => {return Promise.resolve(b);} ); // observable of bools
var postFlat = loggedIn$.map( b => {return Promise.resolve(b);} ).flatMap(x => x); // observable of bools
baseline.subscribe( (value) => console.log(value));
preFlat.subscribe( (value) => console.log(value));
postFlat.subscribe( (value) => console.log(value));