前言
Rxjava，由于其基于事件流的鏈?zhǔn)秸{(diào)用、邏輯簡潔 & 使用簡單的特點，深受各大 Android開發(fā)者的歡迎。
如果還不了解
RxJava，請看文章：Android：這是一篇 清晰 & 易懂的Rxjava 入門教程
-
RxJava如此受歡迎的原因，在于其提供了豐富 & 功能強大的操作符，幾乎能完成所有的功能需求 - 今天，我將為大家詳細(xì)介紹
RxJava操作符中最常用的 過濾操作符，希望你們會喜歡。
Carson帶你學(xué)RxJava系列文章，包括 原理、操作符、應(yīng)用場景、背壓等等，請關(guān)注看文章：Android：這是一份全面 & 詳細(xì)的RxJava學(xué)習(xí)指南
目錄
1. 作用
過濾 / 篩選 被觀察者（Observable）發(fā)送的事件 & 觀察者 （Observer）接收的事件
2. 類型
-
RxJava2中，過濾操作符的類型包括：
示意圖 下面，我將對每個操作符進(jìn)行詳細(xì)講解
3. 應(yīng)用場景 & 對應(yīng)操作符詳解
- 過濾操作符的應(yīng)用場景包括：
- 根據(jù) 指定條件 過濾事件
- 根據(jù) 指定事件數(shù)量 過濾事件
- 根據(jù) 指定時間 過濾事件
- 根據(jù) 指定事件位置 過濾事件
- 下面，我將根據(jù)上述應(yīng)用場景，講解對應(yīng)的操作符使用
注：在使用RxJava 2操作符前，記得在項目的Gradle中添加依賴：
dependencies {
compile 'io.reactivex.rxjava2:rxandroid:2.0.1'
compile 'io.reactivex.rxjava2:rxjava:2.0.7'
// 注：RxJava2 與 RxJava1 不能共存，即依賴不能同時存在
}
3.1 根據(jù) 指定條件 過濾事件
需求場景
通過設(shè)置指定的過濾條件，當(dāng)且僅當(dāng)該事件滿足條件，就將該事件過濾（不發(fā)送）對應(yīng)操作符類型
- 對應(yīng)操作符使用
Filter（）
作用
過濾 特定條件的事件原理
- 具體使用
Observable.create(new ObservableOnSubscribe<Integer>() {
@Override
public void subscribe(ObservableEmitter<Integer> emitter) throws Exception {
// 1. 發(fā)送5個事件
emitter.onNext(1);
emitter.onNext(2);
emitter.onNext(3);
emitter.onNext(4);
emitter.onNext(5);
}
// 2. 采用filter（）變換操作符
}).filter(new Predicate<Integer>() {
// 根據(jù)test()的返回值 對被觀察者發(fā)送的事件進(jìn)行過濾 & 篩選
// a. 返回true，則繼續(xù)發(fā)送
// b. 返回false，則不發(fā)送（即過濾）
@Override
public boolean test(Integer integer) throws Exception {
return integer > 3;
// 本例子 = 過濾了整數(shù)≤3的事件
}
}).subscribe(new Observer<Integer>() {
@Override
public void onSubscribe(Disposable d) {
Log.d(TAG, "開始采用subscribe連接");
}
@Override
public void onNext(Integer value) {
Log.d(TAG, "過濾后得到的事件是："+ value );
}
@Override
public void onError(Throwable e) {
Log.d(TAG, "對Error事件作出響應(yīng)");
}
@Override
public void onComplete() {
Log.d(TAG, "對Complete事件作出響應(yīng)");
}
});
- 測試結(jié)果
ofType（）
作用
過濾 特定數(shù)據(jù)類型的數(shù)據(jù)具體使用
Observable.just(1, "Carson", 3, "Ho", 5)
.ofType(Integer.class) // 篩選出 整型數(shù)據(jù)
.subscribe(new Consumer<Integer>() {
@Override
public void accept( Integer integer) throws Exception {
Log.d(TAG,"獲取到的整型事件元素是： "+ integer);
}
});
- 測試結(jié)果
skip（） / skipLast（）
作用
跳過某個事件具體使用
// 使用1：根據(jù)順序跳過數(shù)據(jù)項
Observable.just(1, 2, 3, 4, 5)
.skip(1) // 跳過正序的前1項
.skipLast(2) // 跳過正序的后2項
.subscribe(new Consumer<Integer>() {
@Override
public void accept( Integer integer) throws Exception {
Log.d(TAG,"獲取到的整型事件元素是： "+ integer);
}
});
// 使用2：根據(jù)時間跳過數(shù)據(jù)項
// 發(fā)送事件特點：發(fā)送數(shù)據(jù)0-5，每隔1s發(fā)送一次，每次遞增1；第1次發(fā)送延遲0s
Observable.intervalRange(0, 5, 0, 1, TimeUnit.SECONDS)
.skip(1, TimeUnit.SECONDS) // 跳過第1s發(fā)送的數(shù)據(jù)
.skipLast(1, TimeUnit.SECONDS) // 跳過最后1s發(fā)送的數(shù)據(jù)
.subscribe(new Consumer<Long>() {
@Override
public void accept( Long along ) throws Exception {
Log.d(TAG,"獲取到的整型事件元素是： "+ along);
}
});
- 測試結(jié)果
distinct（） / distinctUntilChanged（）
作用
過濾事件序列中重復(fù)的事件 / 連續(xù)重復(fù)的事件具體使用
// 使用1：過濾事件序列中重復(fù)的事件
Observable.just(1, 2, 3, 1 , 2 )
.distinct()
.subscribe(new Consumer<Integer>() {
@Override
public void accept( Integer integer) throws Exception {
Log.d(TAG,"不重復(fù)的整型事件元素是： "+ integer);
}
});
// 使用2：過濾事件序列中 連續(xù)重復(fù)的事件
// 下面序列中，連續(xù)重復(fù)的事件 = 3、4
Observable.just(1,2,3,1,2,3,3,4,4 )
.distinctUntilChanged()
.subscribe(new Consumer<Integer>() {
@Override
public void accept( Integer integer) throws Exception {
Log.d(TAG,"不連續(xù)重復(fù)的整型事件元素是： "+ integer);
}
});
- 測試結(jié)果
3.2 根據(jù) 指定事件數(shù)量 過濾事件
需求場景
通過設(shè)置指定的事件數(shù)量，僅發(fā)送特定數(shù)量的事件對應(yīng)操作符類型
take（）&takeLast（）對應(yīng)操作符使用
take（）
作用
指定觀察者最多能接收到的事件數(shù)量原理
- 具體使用
Observable.create(new ObservableOnSubscribe<Integer>() {
@Override
public void subscribe(ObservableEmitter<Integer> emitter) throws Exception {
// 1. 發(fā)送5個事件
emitter.onNext(1);
emitter.onNext(2);
emitter.onNext(3);
emitter.onNext(4);
emitter.onNext(5);
}
// 采用take（）變換操作符
// 指定了觀察者只能接收2個事件
}).take(2)
.subscribe(new Observer<Integer>() {
@Override
public void onSubscribe(Disposable d) {
Log.d(TAG, "開始采用subscribe連接");
}
@Override
public void onNext(Integer value) {
Log.d(TAG, "過濾后得到的事件是："+ value );
}
@Override
public void onError(Throwable e) {
Log.d(TAG, "對Error事件作出響應(yīng)");
}
@Override
public void onComplete() {
Log.d(TAG, "對Complete事件作出響應(yīng)");
}
});
// 實際上，可理解為：被觀察者還是發(fā)送了5個事件，只是因為操作符的存在攔截了3個事件，最終觀察者接收到的是2個事件
- 測試結(jié)果
takeLast（）
作用
指定觀察者只能接收到被觀察者發(fā)送的最后幾個事件具體使用
Observable.just(1, 2, 3, 4, 5)
.takeLast(3) //指定觀察者只能接受被觀察者發(fā)送的3個事件
.subscribe(new Observer<Integer>() {
@Override
public void onSubscribe(Disposable d) {
Log.d(TAG, "開始采用subscribe連接");
}
@Override
public void onNext(Integer value) {
Log.d(TAG, "過濾后得到的事件是："+ value );
}
@Override
public void onError(Throwable e) {
Log.d(TAG, "對Error事件作出響應(yīng)");
}
@Override
public void onComplete() {
Log.d(TAG, "對Complete事件作出響應(yīng)");
}
});
- 測試結(jié)果
3.3 根據(jù) 指定時間 過濾事件
需求場景
通過設(shè)置指定的時間，僅發(fā)送在該時間內(nèi)的事件對應(yīng)操作符類型
- 對應(yīng)操作符使用
throttleFirst（）/ throttleLast（）
- 作用
在某段時間內(nèi)，只發(fā)送該段時間內(nèi)第1次事件 / 最后1次事件
如，1段時間內(nèi)連續(xù)點擊按鈕，但只執(zhí)行第1次的點擊操作
- 原理示意圖
- 具體使用
<<- 在某段時間內(nèi)，只發(fā)送該段時間內(nèi)第1次事件 ->>
Observable.create(new ObservableOnSubscribe<Integer>() {
@Override
public void subscribe(ObservableEmitter<Integer> e) throws Exception {
// 隔段事件發(fā)送時間
e.onNext(1);
Thread.sleep(500);
e.onNext(2);
Thread.sleep(400);
e.onNext(3);
Thread.sleep(300);
e.onNext(4);
Thread.sleep(300);
e.onNext(5);
Thread.sleep(300);
e.onNext(6);
Thread.sleep(400);
e.onNext(7);
Thread.sleep(300);
e.onNext(8);
Thread.sleep(300);
e.onNext(9);
Thread.sleep(300);
e.onComplete();
}
}).throttleFirst(1, TimeUnit.SECONDS)//每1秒中采用數(shù)據(jù)
.subscribe(new Observer<Integer>() {
@Override
public void onSubscribe(Disposable d) {
Log.d(TAG, "開始采用subscribe連接");
}
@Override
public void onNext(Integer value) {
Log.d(TAG, "接收到了事件"+ value );
}
@Override
public void onError(Throwable e) {
Log.d(TAG, "對Error事件作出響應(yīng)");
}
@Override
public void onComplete() {
Log.d(TAG, "對Complete事件作出響應(yīng)");
}
});
<<- 在某段時間內(nèi)，只發(fā)送該段時間內(nèi)最后1次事件 ->>
Observable.create(new ObservableOnSubscribe<Integer>() {
@Override
public void subscribe(ObservableEmitter<Integer> e) throws Exception {
// 隔段事件發(fā)送時間
e.onNext(1);
Thread.sleep(500);
e.onNext(2);
Thread.sleep(400);
e.onNext(3);
Thread.sleep(300);
e.onNext(4);
Thread.sleep(300);
e.onNext(5);
Thread.sleep(300);
e.onNext(6);
Thread.sleep(400);
e.onNext(7);
Thread.sleep(300);
e.onNext(8);
Thread.sleep(300);
e.onNext(9);
Thread.sleep(300);
e.onComplete();
}
}).throttleLast(1, TimeUnit.SECONDS)//每1秒中采用數(shù)據(jù)
.subscribe(new Observer<Integer>() {
@Override
public void onSubscribe(Disposable d) {
Log.d(TAG, "開始采用subscribe連接");
}
@Override
public void onNext(Integer value) {
Log.d(TAG, "接收到了事件"+ value );
}
@Override
public void onError(Throwable e) {
Log.d(TAG, "對Error事件作出響應(yīng)");
}
@Override
public void onComplete() {
Log.d(TAG, "對Complete事件作出響應(yīng)");
}
});
- 測試結(jié)果
Sample（）
- 作用
在某段時間內(nèi)，只發(fā)送該段時間內(nèi)最新（最后）1次事件
與
throttleLast（）操作符類似
- 具體使用
僅需要把上文的 throttleLast（） 改成Sample（）操作符即可，此處不作過多描述
throttleWithTimeout （） / debounce（）
作用
發(fā)送數(shù)據(jù)事件時，若2次發(fā)送事件的間隔＜指定時間，就會丟棄前一次的數(shù)據(jù)，直到指定時間內(nèi)都沒有新數(shù)據(jù)發(fā)射時才會發(fā)送后一次的數(shù)據(jù)具體使用
Observable.create(new ObservableOnSubscribe<Integer>() {
@Override
public void subscribe(ObservableEmitter<Integer> e) throws Exception {
// 隔段事件發(fā)送時間
e.onNext(1);
Thread.sleep(500);
e.onNext(2); // 1和2之間的間隔小于指定時間1s，所以前1次數(shù)據(jù)（1）會被拋棄，2會被保留
Thread.sleep(1500); // 因為2和3之間的間隔大于指定時間1s，所以之前被保留的2事件將發(fā)出
e.onNext(3);
Thread.sleep(1500); // 因為3和4之間的間隔大于指定時間1s，所以3事件將發(fā)出
e.onNext(4);
Thread.sleep(500); // 因為4和5之間的間隔小于指定時間1s，所以前1次數(shù)據(jù)（4）會被拋棄，5會被保留
e.onNext(5);
Thread.sleep(500); // 因為5和6之間的間隔小于指定時間1s，所以前1次數(shù)據(jù)（5）會被拋棄，6會被保留
e.onNext(6);
Thread.sleep(1500); // 因為6和Complete實踐之間的間隔大于指定時間1s，所以之前被保留的6事件將發(fā)出
e.onComplete();
}
}).throttleWithTimeout(1, TimeUnit.SECONDS)//每1秒中采用數(shù)據(jù)
.subscribe(new Observer<Integer>() {
@Override
public void onSubscribe(Disposable d) {
}
@Override
public void onNext(Integer value) {
Log.d(TAG, "接收到了事件"+ value );
}
@Override
public void onError(Throwable e) {
Log.d(TAG, "對Error事件作出響應(yīng)");
}
@Override
public void onComplete() {
Log.d(TAG, "對Complete事件作出響應(yīng)");
}
});
- 測試結(jié)果
3.4 根據(jù) 指定事件位置 過濾事件
需求場景
通過設(shè)置指定的位置，過濾在該位置的事件對應(yīng)操作符類型
- 對應(yīng)操作符使用
firstElement（） / lastElement（）
作用
僅選取第1個元素 / 最后一個元素具體使用
// 獲取第1個元素
Observable.just(1, 2, 3, 4, 5)
.firstElement()
.subscribe(new Consumer<Integer>() {
@Override
public void accept( Integer integer) throws Exception {
Log.d(TAG,"獲取到的第一個事件是： "+ integer);
}
});
// 獲取最后1個元素
Observable.just(1, 2, 3, 4, 5)
.lastElement()
.subscribe(new Consumer<Integer>() {
@Override
public void accept( Integer integer) throws Exception {
Log.d(TAG,"獲取到的最后1個事件是： "+ integer);
}
});
- 測試結(jié)果
elementAt（）
- 作用
指定接收某個元素（通過 索引值 確定）
注：允許越界，即獲取的位置索引 ＞ 發(fā)送事件序列長度
- 具體使用
// 使用1：獲取位置索引 = 2的 元素
// 位置索引從0開始
Observable.just(1, 2, 3, 4, 5)
.elementAt(2)
.subscribe(new Consumer<Integer>() {
@Override
public void accept( Integer integer) throws Exception {
Log.d(TAG,"獲取到的事件元素是： "+ integer);
}
});
// 使用2：獲取的位置索引 ＞ 發(fā)送事件序列長度時，設(shè)置默認(rèn)參數(shù)
Observable.just(1, 2, 3, 4, 5)
.elementAt(6,10)
.subscribe(new Consumer<Integer>() {
@Override
public void accept( Integer integer) throws Exception {
Log.d(TAG,"獲取到的事件元素是： "+ integer);
}
});
- 測試結(jié)果
elementAtOrError（）
作用
在elementAt（）的基礎(chǔ)上，當(dāng)出現(xiàn)越界情況（即獲取的位置索引 ＞ 發(fā)送事件序列長度）時，即拋出異常具體使用
Observable.just(1, 2, 3, 4, 5)
.elementAtOrError(6)
.subscribe(new Consumer<Integer>() {
@Override
public void accept( Integer integer) throws Exception {
Log.d(TAG,"獲取到的事件元素是： "+ integer);
}
});
- 測試結(jié)果
至此，RxJava2中常用的過濾操作符講解完畢。
4. 實際開發(fā)需求案例
- 在實際開發(fā)中，常見的過濾操作符實際需求場景有：功能防抖 & 聯(lián)想搜索請求優(yōu)化
- 下面，我將通過具體實例來講解上述2個需求
4.1 功能防抖
- 需求場景
- 具體使用
具體請看文章：Android RxJava 實際應(yīng)用講解：功能防抖
4.2 聯(lián)想搜索優(yōu)化
- 場景說明
- 具體使用
具體請看文章：Android RxJava 實際應(yīng)用講解：聯(lián)想搜索優(yōu)化
5. Demo地址
上述所有的Demo源代碼都存放在：Carson_Ho的Github地址：RxJava2_過濾操作符
6. 總結(jié)
- 下面，我將用一張圖總結(jié)
RxJava2中常用的條件 / 布爾操作符
- Carson帶你學(xué)RxJava系列文章：
入門
Carson帶你學(xué)Android：這是一篇清晰易懂的Rxjava入門教程
Carson帶你學(xué)Android：面向初學(xué)者的RxJava使用指南
Carson帶你學(xué)Android：RxJava2.0到底更新了什么？
原理
Carson帶你學(xué)Android：圖文解析RxJava原理
Carson帶你學(xué)Android：手把手帶你源碼分析RxJava
使用教程：操作符
Carson帶你學(xué)Android：RxJava操作符教程
Carson帶你學(xué)Android：RxJava創(chuàng)建操作符
Carson帶你學(xué)Android：RxJava功能性操作符
Carson帶你學(xué)Android：RxJava過濾操作符
Carson帶你學(xué)Android：RxJava組合/合并操作符
Carson帶你學(xué)Android：RxJava變換操作符
Carson帶你學(xué)Android：RxJava條件/布爾操作符
實戰(zhàn)
Carson帶你學(xué)Android：什么時候應(yīng)該使用Rxjava？(開發(fā)場景匯總)
Carson帶你學(xué)Android：RxJava線程控制(含實例講解)
Carson帶你學(xué)Android：圖文詳解RxJava背壓策略
Carson帶你學(xué)Android：RxJava、Retrofit聯(lián)合使用匯總(含實例教程)
Carson帶你學(xué)Android：優(yōu)雅實現(xiàn)網(wǎng)絡(luò)請求嵌套回調(diào)
Carson帶你學(xué)Android：網(wǎng)絡(luò)請求輪詢(有條件)
Carson帶你學(xué)Android：網(wǎng)絡(luò)請求輪詢(無條件)
Carson帶你學(xué)Android：網(wǎng)絡(luò)請求出錯重連(結(jié)合Retrofit)
Carson帶你學(xué)Android：合并數(shù)據(jù)源
Carson帶你學(xué)Android：聯(lián)想搜索優(yōu)化
Carson帶你學(xué)Android：功能防抖
Carson帶你學(xué)Android：從磁盤/內(nèi)存緩存中獲取緩存數(shù)據(jù)
Carson帶你學(xué)Android：聯(lián)合判斷
歡迎關(guān)注Carson_Ho的簡書
不定期分享關(guān)于安卓開發(fā)的干貨，追求短、平、快，但卻不缺深度。
