switchMap - with finally

RxJS 5 switchMap

by Leo

HTML

<script src="https://npmcdn.com/@reactivex/[email protected]/dist/global/Rx.umd.js"></script>

JavaScript

const source = Rx.Observable.fromEvent(document, 'click');
const example = source
    .switchMap(val => Rx.Observable.interval(3000).mapTo('click in 3s!').finally(()=>console.log("!!!! 1")));
const subscribe = example.subscribe(val => console.log(val));

const source2 = Rx.Observable.fromEvent(document, 'keydown');
const example2 = source2
    //.switchMap(val => Rx.Observable.interval(3000).throwError('key in 3s').finally(()=>console.log("!!!! 2")));
    .switchMap(val => Rx.Observable.throw('key in 3s').materialize().delay(3000).dematerialize().finally(()=>console.log("!!!! 2")));
const subscribe2 = example2.subscribe(val => console.log(val));