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