RxJS catch 3

by Leo

HTML

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

JavaScript

let source1 = new Rx.ReplaySubject();
var source2 = Rx.Observable.interval(1000);

var s = Rx.Observable.interval(1000).switchMap((x)=> {
     if(x>2) 
     {
         return Rx.Observable.throw("11111");
     }
     else
     {
        return Rx.Observable.of(x);
     }
});
s.subscribe(source1);


let res = source2.combineLatest(source1, (x,y)=>({x:x, y:y}))

res.catch((e) => alert("!!!!!!!!!!!!"));

var subscription = res.subscribe(
    function (v) {
        console.log('Next: ' + JSON.stringify(v));
    },
    function (err) {
        console.log('Error: ' + err);
    },
    function () {
        console.log('Completed');
    });