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

對(duì) Observable 對(duì)象發(fā)出的每個(gè)值，使用指定的 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--...

以上代碼運(yùn)行后，控制臺(tái)的輸出結(jié)果：

2
3
4
...

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

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--...

以上代碼運(yùn)行后，控制臺(tái)的輸出結(jié)果：

2
2
2
...

對(duì) Observable 發(fā)出值，執(zhí)行 accumulator 指定的運(yùn)算，可以簡(jiǎn)單地認(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)|

以上代碼運(yùn)行后，控制臺(tái)的輸出結(jié)果：

h
he
hel
hell
hello
complete

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

緩沖源 Observable 對(duì)象已發(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]) 

以上代碼運(yùn)行后，控制臺(tái)的輸出結(jié)果：

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

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

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]) 

以上代碼運(yùn)行后，控制臺(tái)的輸出結(jié)果：

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

緩沖源 Observable對(duì)象已發(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]) 

以上代碼運(yùn)行后，控制臺(tái)的輸出結(jié)果：

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

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

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---------...

以上代碼運(yùn)行后，控制臺(tái)的輸出結(jié)果：

0
1
2
0
1
2

concatMap 其實(shí)就是 map 加上 concatAll 的簡(jiǎn)化寫(xiě)法。

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

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-----------...

以上代碼運(yùn)行后，控制臺(tái)的輸出結(jié)果：

0
0
1
2