您的位置:首页 > Web前端 > JavaScript

[RxJS] Use RxJS mergeMap to map and merge high order observables

2016-12-19 21:43 330 查看
Like RxJS switchMap() is a shortcut for map() and switch(), we will see in this lesson how mergeMap() is a shortcut for map() and mergeAll(), and learn its arguments for customised behavior.

const clickObservable = Rx.Observable
.fromEvent(document, 'click');

function performRequest() {
return fetch('https://jsonplaceholder.typicode.com/users/1')
.then(res => res.json());
}

const emailObservable = clickObservable
.mergeMap(click => performRequest(),
(click, res) => res.email, // selector function
3); // number of concurrency

// mergeMap = map ... + ... mergeAll

emailObservable
.subscribe(email => console.log(email));
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: