你必須知道的6個Rxjs的操做符

1.Concat

const getPostOne$ = Rx.Observable.timer(3000).mapTo({id: 1});
const getPostTwo$ = Rx.Observable.timer(1000).mapTo({id: 2});

Rx.Observable.concat(getPostOne$, getPostTwo$).subscribe(res => console.log(res));

合併多個observables，當你一次性subscribe的時候，次操做符會合並多個observable的結果到輸出的obserable中。

若是你的關注點在於輸出的順序的狀況下，能夠使用此操做符。好比當你須要按順序發送ajax請求的時候能夠使用此操做符。

2.forkJoin

forkJoin是Promise.all()方法的Rx版本。

const getPostOne$ = Rx.Observable.timer(1000).mapTo({id: 1});
const getPostTwo$ = Rx.Observable.timer(2000).mapTo({id: 2});

Rx.Observable.forkJoin(getPostOne$, getPostTwo$).subscribe(res => console.log(res)) 
// 打印[{id: 1}, {id: 2}]

當你須要併發的運行observable的時候使用此操做符。

3.mergeMap

const post$ = Rx.Observable.of({id: 1});
const getPostInfo$ = Rx.Observable.timer(3000).mapTo({title: "Post title"});

const posts$ = post$.mergeMap(post => getPostInfo$).subscribe(res => console.log(res));

首先說下Rx中的兩個術語：

1.source observable 這裏指的是post$

2.inner observable 這裏指的是getPostInfo$

當inner observable發出值得時候，合併值到輸出的observable中。

4.pairWise

// Tracking the scroll delta
Rx.Observable
  .fromEvent(document, 'scroll')
  .map(e => window.pageYOffset)
  .pairwise()
  .subscribe(pair => console.log(pair)); // pair[1] - pair[0]

把當前的值和上一個值做爲數組輸出。如上示例當觸發scroll事件的時候能夠輸出[10, 11] [11, 12] [12, 13]...

5.switchMap

const clicks$ = Rx.Observable.fromEvent(document, 'click');
const innerObservable$ = Rx.Observable.interval(1000);

clicks$.switchMap(event => innerObservable$)
                    .subscribe(val => console.log(val));

在這個示例中，每當點擊document的時候以前的interval的subscription會被取消而且會開始一個新的值。

6.combineLatest

const clicks$ = Rx.Observable.fromEvent(document, 'click');
const innerObservable$ = Rx.Observable.interval(1000);

clicks$.switchMap(event => innerObservable$)
                    .subscribe(val => console.log(val));

若是子流a在等待其餘流發射數據期間又發射了新數據並且其餘流未發送數據，則使用子流最新發射的數據進行合併。