資訊專(zhuān)欄INFORMATION COLUMN
摘要：過(guò)濾類(lèi)操作符主要包含等等。獲取房源列表中的最后一套房源小區(qū)房源描述程序輸出小區(qū)中糧海景壹號(hào)房源描述南北通透，豪華五房只發(fā)射觀測(cè)序列中符合條件的最后一個(gè)數(shù)據(jù)項(xiàng)。
轉(zhuǎn)載請(qǐng)注明出處：https://zhuanlan.zhihu.com/p/21966621
RxJava系列1(簡(jiǎn)介)
RxJava系列2(基本概念及使用介紹)
RxJava系列3(轉(zhuǎn)換操作符)
RxJava系列4(過(guò)濾操作符)
RxJava系列5(組合操作符)
RxJava系列6(從微觀角度解讀RxJava源碼)
RxJava系列7(最佳實(shí)踐)
前面一篇文章中我們介紹了轉(zhuǎn)換類(lèi)操作符，那么這一章我們就來(lái)介紹下過(guò)濾類(lèi)的操作符。顧名思義，這類(lèi)operators主要用于對(duì)事件數(shù)據(jù)的篩選過(guò)濾，只返回滿(mǎn)足我們條件的數(shù)據(jù)。過(guò)濾類(lèi)操作符主要包含： Filter Take TakeLast TakeUntil Skip SkipLast ElementAt Debounce Distinct DistinctUntilChanged First Last等等。
Filterfilter(Func1)用來(lái)過(guò)濾觀測(cè)序列中我們不想要的值，只返回滿(mǎn)足條件的值，我們看下原理圖：
還是拿前面文章中的小區(qū)Community[] communities來(lái)舉例，假設(shè)我需要賽選出所有房源數(shù)大于10個(gè)的小區(qū)，我們可以這樣實(shí)現(xiàn)：
Observable.from(communities)
.filter(new Func1() {
@Override
public Boolean call(Community community) {
return community.houses.size()>10;
}
}).subscribe(new Action1() {
@Override
public void call(Community community) {
System.out.println(community.name);
}
});
Take
take(int)用一個(gè)整數(shù)n作為一個(gè)參數(shù)，從原始的序列中發(fā)射前n個(gè)元素.
現(xiàn)在我們需要取小區(qū)列表communities中的前10個(gè)小區(qū)
Observable.from(communities)
.take(10)
.subscribe(new Action1() {
@Override
public void call(Community community) {
System.out.println(community.name);
}
});
TakeLast
takeLast(int)同樣用一個(gè)整數(shù)n作為參數(shù)，只不過(guò)它發(fā)射的是觀測(cè)序列中后n個(gè)元素。
獲取小區(qū)列表communities中的后3個(gè)小區(qū)
Observable.from(communities)
.takeLast(3)
.subscribe(new Action1() {
@Override
public void call(Community community) {
System.out.println(community.name);
}
});
TakeUntil
takeUntil(Observable)訂閱并開(kāi)始發(fā)射原始Observable，同時(shí)監(jiān)視我們提供的第二個(gè)Observable。如果第二個(gè)Observable發(fā)射了一項(xiàng)數(shù)據(jù)或者發(fā)射了一個(gè)終止通知，takeUntil()返回的Observable會(huì)停止發(fā)射原始Observable并終止。
ObservableobservableA = Observable.interval(300, TimeUnit.MILLISECONDS); Observable observableB = Observable.interval(800, TimeUnit.MILLISECONDS); observableA.takeUntil(observableB) .subscribe(new Subscriber () { @Override public void onCompleted() { System.exit(0); } @Override public void onError(Throwable e) { } @Override public void onNext(Long aLong) { System.out.println(aLong); } }); try { Thread.sleep(Integer.MAX_VALUE); } catch (InterruptedException e) { e.printStackTrace(); }
程序輸出：
0 1
takeUntil(Func1)通過(guò)Func1中的call方法來(lái)判斷是否需要終止發(fā)射數(shù)據(jù)。
Observable.just(1, 2, 3, 4, 5, 6, 7)
.takeUntil(new Func1() {
@Override
public Boolean call(Integer integer) {
return integer >= 5;
}
}).subscribe(new Action1() {
@Override
public void call(Integer integer) {
System.out.println(integer);
}
});
程序輸出：
1 2 3 4 5Skip
skip(int)讓我們可以忽略O(shè)bservable發(fā)射的前n項(xiàng)數(shù)據(jù)。
過(guò)濾掉小區(qū)列表communities中的前5個(gè)小區(qū)
Observable.from(communities)
.skip(5)
.subscribe(new Action1() {
@Override
public void call(Community community) {
System.out.println(community.name);
}
});
SkipLast
skipLast(int)忽略O(shè)bservable發(fā)射的后n項(xiàng)數(shù)據(jù)。
ElementAtelementAt(int)用來(lái)獲取元素Observable發(fā)射的事件序列中的第n項(xiàng)數(shù)據(jù)，并當(dāng)做唯一的數(shù)據(jù)發(fā)射出去。
Debouncedebounce(long, TimeUnit)過(guò)濾掉了由Observable發(fā)射的速率過(guò)快的數(shù)據(jù)；如果在一個(gè)指定的時(shí)間間隔過(guò)去了仍舊沒(méi)有發(fā)射一個(gè)，那么它將發(fā)射最后的那個(gè)。通常我們用來(lái)結(jié)合RxBing(Jake Wharton大神使用RxJava封裝的Android UI組件)使用，防止button重復(fù)點(diǎn)擊。
debounce(Func1)可以根據(jù)Func1的call方法中的函數(shù)來(lái)過(guò)濾，F(xiàn)unc1中的中的call方法返回了一個(gè)臨時(shí)的Observable，如果原始的Observable在發(fā)射一個(gè)新的數(shù)據(jù)時(shí)，上一個(gè)數(shù)據(jù)根據(jù)Func1的call方法生成的臨時(shí)Observable還沒(méi)結(jié)束，那么上一個(gè)數(shù)據(jù)就會(huì)被過(guò)濾掉。
Distinctdistinct()的過(guò)濾規(guī)則是只允許還沒(méi)有發(fā)射過(guò)的數(shù)據(jù)通過(guò)，所有重復(fù)的數(shù)據(jù)項(xiàng)都只會(huì)發(fā)射一次。
過(guò)濾掉一段數(shù)字中的重復(fù)項(xiàng)：
Observable.just(2, 1, 2, 2, 3, 4, 3, 4, 5, 5)
.distinct()
.subscribe(new Action1() {
@Override
public void call(Integer i) {
System.out.print(i + " ");
}
});
程序輸出：
2 1 3 4 5
distinct(Func1)參數(shù)中的Func1中的call方法會(huì)根據(jù)Observable發(fā)射的值生成一個(gè)Key，然后比較這個(gè)key來(lái)判斷兩個(gè)數(shù)據(jù)是不是相同；如果判定為重復(fù)則會(huì)和distinct()一樣過(guò)濾掉重復(fù)的數(shù)據(jù)項(xiàng)。
假設(shè)我們要過(guò)濾掉一堆房源中小區(qū)名重復(fù)的小區(qū)：
