摘要：操作符防抖動(dòng)，只有當(dāng)另一個(gè)發(fā)射值時(shí)，才取源的最新數(shù)據(jù)進(jìn)行發(fā)射，其他數(shù)據(jù)取消發(fā)射。輸出從源數(shù)據(jù)集的第一項(xiàng)開始進(jìn)行發(fā)射，直到另一個(gè)開始發(fā)射第一個(gè)值時(shí)，源停止發(fā)射值。

防抖動(dòng)，只有當(dāng)另一個(gè)Observable發(fā)射值時(shí)，才取源Obervable的最新數(shù)據(jù)進(jìn)行發(fā)射，其他數(shù)據(jù)取消發(fā)射。

// 每次點(diǎn)擊，且當(dāng)計(jì)時(shí)器的最新值未被發(fā)射時(shí)，才從計(jì)時(shí)器發(fā)射一個(gè)值
Rx.Observable.interval( 1000 )
    .debounce(( ) => Rx.Observable.fromEvent(document, "click"))
    .subscribe(x => console.log( x ));

防抖動(dòng)，一段時(shí)間內(nèi)，只取最新數(shù)據(jù)進(jìn)行發(fā)射，其他數(shù)據(jù)取消發(fā)射。

// 每隔一秒，輸出一個(gè)計(jì)時(shí)器的值
Rx.Observable.interval( 1000 )
    .debounceTime( 500 )
    .subscribe(x => console.log( x ))

　去除重復(fù)的值

// 去除重復(fù)的值，輸出A,B,C,b
Rx.Observable.of("A", "B", "C", "A", "b", "B")
    .distinct( )
    .subscribe( x => console.log( x ))

去除連續(xù)重復(fù)的值

// 去除連續(xù)重復(fù)的元素，輸出A,B,A,B,A
Rx.Observable.of("A", "B", "B", "A", "B", "A", "A")
    .distinctUntilChanged( )
    .subscribe( x => console.log( x ))

　　　　去除連續(xù)項(xiàng)中，擁有相同給予key值的value的項(xiàng)

let items = [
    { age: 4, name: "Foo"},
    { age: 7, name: "Bar"},
    { age: 5, name: "Foo"},
    { age: 6, name: "Foo"}
]
Rx.Observable.of( ...items )
    .distinctUntilKeyChanged("name") 
    .subscribe( x => console.log( x ))

// 輸出
//  { age: 4, name: "Foo"}
//  { age: 7, name: "Bar"}
//  { age: 5, name: "Foo"}

只發(fā)射指定位置的元素

// 下標(biāo)從0開始，輸出 ‘A’
Rx.Observable.of("A", "B", "B", "A", "B", "A", "A")
    .elementAt( 3 )
    .subscribe( x => console.log( x ))

自定義過(guò)濾規(guī)則，符合才把該值進(jìn)行發(fā)射

// 輸出奇數(shù)：1,2,5,7,9,1
Rx.Observable.of(1,3,2,5,4,7,6,9,1)
    .filter( x => x % 2 !== 0 )
    .subscribe( x => console.log( x ))

只輸出第一個(gè)元素

// 只輸出第一個(gè)元素，輸出：1
Rx.Observable.of(1,3,2,5,4,7,6,9,1)
    .first( )
    .subscribe( x => console.log( x ))

　忽略所有值，一個(gè)也不發(fā)射

// 啥也不輸出
Rx.Observable.of(1,3,2,5,4,7,6,9,1)
    .ignoreElements( )
    .subscribe( x => console.log( x ))

　　audit當(dāng)另一個(gè)Observable發(fā)射值前，源Observable的值會(huì)被忽略，當(dāng)另一個(gè)Observable發(fā)射值時(shí)，才從源Observable發(fā)射一個(gè)最新值，然后重復(fù)上述過(guò)程。

　　auditTime在指定等待時(shí)間內(nèi)，源Observable的值會(huì)被忽略，等待結(jié)束后，發(fā)射一個(gè)源Observable的最新值，然后重復(fù)上述過(guò)程。

　　　　他們與throttle的區(qū)別是，第一個(gè)值的發(fā)射，是先等待再發(fā)射，而throttle是先發(fā)射第一個(gè)值，然后再等待。

// auditTime
// 輸出2,5,8,11,13...
Rx.Observable.interval( 1000 )
    .auditTime( 2000 )
    .subscribe( x => console.log( x ))

　返回源數(shù)據(jù)集的最后一個(gè)條目

// 返回最后一個(gè)條目，輸出：5
Rx.Observable.of(1,2,3,4,5)
    .last( )
    .subscribe( x => console.log( x ))

　當(dāng)另一個(gè)Observable發(fā)射值時(shí)，才從源Observable數(shù)據(jù)集發(fā)射一個(gè)最新值

// 每次點(diǎn)擊輸出一個(gè)計(jì)時(shí)器的最新值
Rx.Observable.interval( 1000 )
    .sample( Rx.Observable.fromEvent( document, "click" ))
    .subscribe( x => console.log( x ))

　每隔一定的時(shí)間間隔，發(fā)射一個(gè)源Observable數(shù)據(jù)集的最新值

// 每隔2秒，分別輸出 0,2,4,6,8....
Rx.Observable.interval( 1000 )
   .sampleTime( 2000 )
   .subscribe( x => console.log( x ))

　若源Observable數(shù)據(jù)集只有一個(gè)數(shù)據(jù)項(xiàng)，則輸出該項(xiàng)。若多于一個(gè)數(shù)據(jù)項(xiàng)，則報(bào)錯(cuò)

// 輸出 1
Rx.Observable.of( 1 )
    .single( )
    .subscribe( x => console.log( x ))

　跳過(guò)源Observable數(shù)據(jù)集的n個(gè)數(shù)據(jù)，然后才發(fā)射值。

// 跳過(guò)開頭2個(gè)，輸出3,4
Rx.Observable.of(1,2,3,4)
    .skip( 2 )
    .subscribe( x => console.log( x ))

忽略源Observable開頭的一系列值，直到當(dāng)另一個(gè)Observable開始發(fā)射值，才會(huì)從源Observable開始發(fā)射值

// 3秒后，才每秒發(fā)射計(jì)時(shí)器的值，輸出：2,3,4,5,6.....
Rx.Observable.interval( 1000 )
    .skipUntil( Rx.Observable.of( 1 ).delay( 3000 ))
    .subscribe( x => console.log( x ))

忽略源Observable開頭的一系列值，直到有一項(xiàng)符合條件，才開始從源Observable的該值開始，開始發(fā)射值。

// 輸出4,5,3,2,1
Rx.Observable.of( 1, 2, 3, 4, 5, 3, 2, 1)
    .skipWhile( x => x < 4 )
    .subscribe( x => console.log( x ))
　　十八、take

　　　　從源Obervable的開頭開始，拿到n個(gè)數(shù)據(jù)項(xiàng)進(jìn)行發(fā)射，其余的數(shù)據(jù)項(xiàng)將被忽略。

// 每秒輸出：0,1,2 后結(jié)束
Rx.Observable.interval( 1000 )
    .take( 3 )
    .subscribe( x => console.log( x ))

用于獲取 Observable 對(duì)象發(fā)出的前 n 項(xiàng)值，取完后就結(jié)束。

var source = Rx.Observable.interval(1000);
var example = source.take(3);

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

示例 marble 圖：

source : -----0-----1-----2-----3--..
                take(3)
example: -----0-----1-----2|

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

0
1
2
complete

從源Obervable的倒數(shù)第一個(gè)向前數(shù)，拿到n個(gè)數(shù)據(jù)項(xiàng)并進(jìn)行發(fā)射，從開頭開始的的數(shù)據(jù)項(xiàng)將被忽略。

// 輸出5,6,7
Rx.Observable.of( 1,2,3,4,5,6,7 )
    .takeLast( 3 )
    .subscribe( x => console.log( x ))

從源Observable數(shù)據(jù)集的第一項(xiàng)開始進(jìn)行發(fā)射，直到另一個(gè)Observable開始發(fā)射第一個(gè)值時(shí)，源Observable停止發(fā)射值。

// 3秒后停止計(jì)時(shí)器的值輸出
Rx.Observable.interval( 1000 )
    .takeUntil( Rx.Observable.of( 1 ).delay( 3000 ))
    .subscribe( x => console.log( x ))

從源Observable數(shù)據(jù)集的第一個(gè)數(shù)據(jù)項(xiàng)開始發(fā)射值，直到遇到符合條件的第一個(gè)數(shù)據(jù)項(xiàng)后，停止源Observable數(shù)據(jù)集的發(fā)射

// 輸出：1,2,3
Rx.Observable.of( 1,2,3,4,3,2,1)
    .takeWhile( x => x < 4 )
    .subscribe( x => console.log( x ))

每當(dāng)源Observable數(shù)據(jù)集發(fā)射一個(gè)數(shù)據(jù)項(xiàng)時(shí)，會(huì)等待另一個(gè)Observable發(fā)射值，在等待期間源Observable的值將被忽略并不會(huì)發(fā)射，直到另一個(gè)Observable發(fā)射了一個(gè)值時(shí)，才把源Observable的最新值進(jìn)行發(fā)射

// 輸出0,3,6,9,12.....
// 每次輸出一個(gè)值，至少等待兩秒后，才輸出最新值
Rx.Observable.interval( 1000 )
    .throttle( x => Rx.Observable.interval( 2000 ))
    .subscribe( x => console.log( x ))

每當(dāng)源Observable數(shù)據(jù)集發(fā)射一個(gè)數(shù)據(jù)項(xiàng)時(shí)，會(huì)等待n秒，n秒后輸出源Observable的最新值。

// 輸出0,3,6,9,12.....
Rx.Observable.interval( 1000 )
    .throttleTime( 2000 )
    .subscribe( x => console.log( x ))