JSFiddle - React, Tailwind, and code Playground

by mattpodwysocki

HTML

<script src="http://cdnjs.cloudflare.com/ajax/libs/rxjs/2.1.20/rx.js
"></script>
<script src="http://cdnjs.cloudflare.com/ajax/libs/rxjs/2.1.20/rx.time.js
"></script>

JavaScript

var xs = Rx.Observable.interval(1000)
.map(function (x) {
    if(x === 4) { throw new Error('woops'); }
    return "["+x+"] "+ Date.now();
})
.delay(10000)
.map(function (x) { return x+"~~>"+ Date.now(); });
        
xs.subscribe( 
    console.log.bind(console), 
    function (e) { console.log("["+e.message+"]"); },
    function () { console.log("!"); }
);
 
var zs = Rx.Observable.interval(1000)
.map(function (x) {
    if(x === 4) { throw new Error('woops'); }
    return "["+x+"] "+ Date.now();
})
.map(function (x) { return Rx.Observable.timer(10000).map(function () { return x; }); }).concatObservable()
.map(function (x) { return x+"~~>"+ Date.now(); });
 
zs.subscribe( 
    console.log.bind(console), 
    function (e) { console.log("["+e.message+"]"); },
    function () { console.log("!"); }
);