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