摘要：對對象發(fā)出的每個值，使用指定的函數(shù)，進(jìn)行映射處理。示例圖以上代碼運行后，控制臺的輸出結(jié)果緩沖源對象已發(fā)出的值，直到大小達(dá)到給定的最大。該操作符也會先處理前一個對象，在處理下一個對象。

對 Observable 對象發(fā)出的每個值，使用指定的 project 函數(shù)，進(jìn)行映射處理。

var source = Rx.Observable.interval(1000);
var newest = source.map(x => x + 2); 
newest.subscribe(console.log);

示例 marble 圖：

source: -----0-----1-----2-----3--...
            map(x => x + 2)
newest: -----2-----3-----4-----5--...

以上代碼運行后，控制臺的輸出結(jié)果：

2
3
4
...

對 Observable 對象發(fā)出的每個值，映射成固定的值。

var source = Rx.Observable.interval(1000);
var newest = source.mapTo(2); 

newest.subscribe(console.log);

示例 marble 圖：

source: -----0-----1-----2-----3--...
                mapTo(2)
newest: -----2-----2-----2-----2--...

以上代碼運行后，控制臺的輸出結(jié)果：

2
2
2
...

對 Observable 發(fā)出值，執(zhí)行 accumulator 指定的運算，可以簡單地認(rèn)為是 Observable 版本的 Array.prototype.reduce 。

var source = Rx.Observable.from("hello")
             .zip(Rx.Observable.interval(600), (x, y) => x);

var example = source.scan((origin, next) => origin + next, "");

example.subscribe({
    next: (value) => { console.log(value); },
    error: (err) => { console.log("Error: " + err); },
    complete: () => { console.log("complete"); }
});

示例 marble 圖：

source : ----h----e----l----l----o|
    scan((origin, next) => origin + next, "")
example: ----h----(he)----(hel)----(hell)----(hello)|

以上代碼運行后，控制臺的輸出結(jié)果：

h
he
hel
hell
hello
complete

(備注：scan 與 reduce 最大的差別就是 scan 最終返回的一定是一個 Observable 對象，而 reduce 的返回類型不是固定的)

緩沖源 Observable 對象已發(fā)出的值，直到 closingNotifier 觸發(fā)后，才統(tǒng)一輸出緩存的元素

var source = Rx.Observable.interval(300);
var source2 = Rx.Observable.interval(1000);
var example = source.buffer(source2);

example.subscribe({
    next: (value) => { console.log(value); },
    error: (err) => { console.log("Error: " + err); },
    complete: () => { console.log("complete"); }
});

示例 marble 圖：

source : --0--1--2--3--4--5--6--7..
source2: ---------0---------1--------...
            buffer(source2)
example: ---------([0,1,2])---------([3,4,5]) 

以上代碼運行后，控制臺的輸出結(jié)果：

[0,1,2]
[3,4,5]
[6,7,8]
....

設(shè)定源 Observable 對象已發(fā)出的值的緩沖時間。

var source = Rx.Observable.interval(300);
var example = source.bufferTime(1000);

example.subscribe({
    next: (value) => { console.log(value); },
    error: (err) => { console.log("Error: " + err); },
    complete: () => { console.log("complete"); }
});

示例 marble 圖：

source : --0--1--2--3--4--5--6--7..
            bufferTime(1000)
example: ---------([0,1,2])---------([3,4,5]) 

以上代碼運行后，控制臺的輸出結(jié)果：

[0,1,2]
[3,4,5]
[6,7,8]
....

緩沖源 Observable對象已發(fā)出的值，直到大小達(dá)到給定的最大 bufferSize 。

ar source = Rx.Observable.interval(300);
var example = source.bufferCount(3);

example.subscribe({
    next: (value) => { console.log(value); },
    error: (err) => { console.log("Error: " + err); },
    complete: () => { console.log("complete"); }
});

示例 marble 圖：

source : --0--1--2--3--4--5--6--7..
            bufferCount(3)
example: ---------([0,1,2])---------([3,4,5]) 

以上代碼運行后，控制臺的輸出結(jié)果：

[0,1,2]
[3,4,5]
[6,7,8]
....

對每個 Observable 對象發(fā)出的值，進(jìn)行映射處理，并進(jìn)行合并。該操作符也會先處理前一個 Observable 對象，在處理下一個 Observable 對象。

var source = Rx.Observable.fromEvent(document.body, "click");

var example = source.concatMap(
                e => Rx.Observable.interval(100).take(3));
                
example.subscribe({
    next: (value) => { console.log(value); },
    error: (err) => { console.log("Error: " + err); },
    complete: () => { console.log("complete"); }
});

示例 marble 圖：

source : -----------c--c------------------...
        concatMap(c => Rx.Observable.interval(100).take(3))
example: -------------0-1-2-0-1-2---------...

以上代碼運行后，控制臺的輸出結(jié)果：

0
1
2
0
1
2

concatMap 其實就是 map 加上 concatAll 的簡化寫法。

對源 Observable 對象發(fā)出的值，做映射處理。若有新的 Observable 對象出現(xiàn)，會在新的 Observable 對象發(fā)出新值后，退訂前一個未處理完的 Observable 對象。

var source = Rx.Observable.fromEvent(document.body, "click");
var example = source.switchMap(
                    e => Rx.Observable.interval(100).take(3));
                
example.subscribe({
    next: (value) => { console.log(value); },
    error: (err) => { console.log("Error: " + err); },
    complete: () => { console.log("complete"); }
});

示例 marble 圖：

source : -----------c--c-----------------...
        concatMap(c => Rx.Observable.interval(100).take(3))
example: -------------0--0-1-2-----------...

以上代碼運行后，控制臺的輸出結(jié)果：

0
0
1
2