JSFiddle - React, Tailwind, and code Playground

by subhadipghosh

HTML

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

Babel + JSX

const src$ = new Rx.Observable.create(function (observer) {   
// Each next inside Observable will trigger subscribed function. 
 observer.next('hi');  
    observer.next('hello');
    setTimeout(function () {
        observer.next('bye');
        observer.complete();// Will end the observer
    }, 3000);
    //observer.error(new Error('Error'));// <-- uncomment the throw error
});

src$.subscribe(
    function (e) {
        console.log(e);// will execute when any change in Observable 
    },
    function (er) {
        console.log(er);// will be called when error
    }, function () {
        console.log('completed'); // will be called when done
    }
 );
////----------NOTE: Check Console(F12) for Results------------------/////