這可能是最好的 RxJava 2.x 入門教程系列專欄
文章鏈接：
這可能是最好的 RxJava 2.x 入門教程(完結版)【重磅推出】
這可能是最好的 RxJava 2.x 入門教程（一）
這可能是最好的 RxJava 2.x 入門教程（二）
這可能是最好的 RxJava 2.x 入門教程（三）
這可能是最好的 RxJava 2.x 入門教程（四）
這可能是最好的 RxJava 2.x 入門教程（五）
GitHub 代碼同步更新：https://github.com/nanchen2251/RxJava2Examples
為了滿足大家的饑渴難耐竖席，GitHub 將同步更新代碼养距，主要包含基本的代碼封裝，RxJava 2.x 所有操作符應用場景介紹和實際應用場景，后期除了 RxJava 可能還會增添其他東西，總之，GitHub 上的 Demo 專為大家傾心打造。傳送門：https://github.com/nanchen2251/RxJava2Examples
前言
年輕的老司機們，我這么勤的為大家分享弥虐，卻少有催更的，好吧媚赖。其實寫這個系列不是為了吸睛霜瘪，那咱們繼續(xù)寫我們的 RxJava 2.x 的操作符。
正題
distinct
這個操作符非常的簡單惧磺、通俗颖对、易懂，就是簡單的去重嘛豺妓，我甚至都不想貼代碼惜互，但人嘛，總得持之以恒琳拭。
Observable.just(1, 1, 1, 2, 2, 3, 4, 5)
.distinct()
.subscribe(new Consumer<Integer>() {
@Override
public void accept(@NonNull Integer integer) throws Exception {
mRxOperatorsText.append("distinct : " + integer + "\n");
Log.e(TAG, "distinct : " + integer + "\n");
}
});
輸出：
Log 日志顯而易見训堆，我們在經過
dinstinct() 后接收器接收到的事件只有1,2,3,4,5了。
Filter
信我白嘁，Filter 你會很常用的坑鱼，它的作用也很簡單，過濾器嘛÷沉ぃ可以接受一個參數呼股，讓其過濾掉不符合我們條件的值
Observable.just(1, 20, 65, -5, 7, 19)
.filter(new Predicate<Integer>() {
@Override
public boolean test(@NonNull Integer integer) throws Exception {
return integer >= 10;
}
}).subscribe(new Consumer<Integer>() {
@Override
public void accept(@NonNull Integer integer) throws Exception {
mRxOperatorsText.append("filter : " + integer + "\n");
Log.e(TAG, "filter : " + integer + "\n");
}
});
輸出：
可以看到，我們過濾器舍去了小于 10 的值画恰，所以最好的輸出只有 20, 65, 19彭谁。
buffer
buffer 操作符接受兩個參數，buffer(count,skip)允扇，作用是將 Observable 中的數據按 skip (步長) 分成最大不超過 count 的 buffer 缠局，然后生成一個 Observable 。也許你還不太理解考润，我們可以通過我們的示例圖和示例代碼來進一步深化它狭园。
Observable.just(1, 2, 3, 4, 5)
.buffer(3, 2)
.subscribe(new Consumer<List<Integer>>() {
@Override
public void accept(@NonNull List<Integer> integers) throws Exception {
mRxOperatorsText.append("buffer size : " + integers.size() + "\n");
Log.e(TAG, "buffer size : " + integers.size() + "\n");
mRxOperatorsText.append("buffer value : ");
Log.e(TAG, "buffer value : " );
for (Integer i : integers) {
mRxOperatorsText.append(i + "");
Log.e(TAG, i + "");
}
mRxOperatorsText.append("\n");
Log.e(TAG, "\n");
}
});
輸出：
如圖，我們把 1, 2, 3, 4, 5 依次發(fā)射出來糊治，經過
buffer 操作符唱矛，其中參數 skip 為 2， count 為 3井辜，而我們的輸出 依次是 123绎谦，345，5粥脚。顯而易見燥滑，我們 buffer 的第一個參數是 count，代表最大取值阿逃，在事件足夠的時候，一般都是取 count 個值赃蛛，然后每次跳過 skip 個事件恃锉。其實看 Log 日志，我相信大家都明白了呕臂。
timer
timer 很有意思破托，相當于一個定時任務。在 1.x 中它還可以執(zhí)行間隔邏輯歧蒋，但在 2.x 中此功能被交給了 interval土砂，下一個會介紹。但需要注意的是谜洽，timer 和 interval 均默認在新線程萝映。
mRxOperatorsText.append("timer start : " + TimeUtil.getNowStrTime() + "\n");
Log.e(TAG, "timer start : " + TimeUtil.getNowStrTime() + "\n");
Observable.timer(2, TimeUnit.SECONDS)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread()) // timer 默認在新線程，所以需要切換回主線程
.subscribe(new Consumer<Long>() {
@Override
public void accept(@NonNull Long aLong) throws Exception {
mRxOperatorsText.append("timer :" + aLong + " at " + TimeUtil.getNowStrTime() + "\n");
Log.e(TAG, "timer :" + aLong + " at " + TimeUtil.getNowStrTime() + "\n");
}
});
輸出：
顯而易見阐虚，當我們兩次點擊按鈕觸發(fā)這個事件的時候序臂，接收被延遲了 2 秒。
interval
如同我們上面可說实束，interval 操作符用于間隔時間執(zhí)行某個操作奥秆，其接受三個參數逊彭，分別是第一次發(fā)送延遲，間隔時間构订，時間單位侮叮。
mRxOperatorsText.append("interval start : " + TimeUtil.getNowStrTime() + "\n");
Log.e(TAG, "interval start : " + TimeUtil.getNowStrTime() + "\n");
Observable.interval(3,2, TimeUnit.SECONDS)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread()) // 由于interval默認在新線程，所以我們應該切回主線程
.subscribe(new Consumer<Long>() {
@Override
public void accept(@NonNull Long aLong) throws Exception {
mRxOperatorsText.append("interval :" + aLong + " at " + TimeUtil.getNowStrTime() + "\n");
Log.e(TAG, "interval :" + aLong + " at " + TimeUtil.getNowStrTime() + "\n");
}
});
輸出：
如同 Log 日志一樣悼瘾，第一次延遲了 3 秒后接收到囊榜，后面每次間隔了 2 秒。
然而分尸，心細的小伙伴可能會發(fā)現锦聊，由于我們這個是間隔執(zhí)行，所以當我們的Activity 都銷毀的時候箩绍，實際上這個操作還依然在進行孔庭，所以，我們得花點小心思讓我們在不需要它的時候干掉它材蛛。查看源碼發(fā)現圆到，我們subscribe(Cousumer<? super T> onNext)返回的是Disposable，我們可以在這上面做文章卑吭。
@Override
protected void doSomething() {
mRxOperatorsText.append("interval start : " + TimeUtil.getNowStrTime() + "\n");
Log.e(TAG, "interval start : " + TimeUtil.getNowStrTime() + "\n");
mDisposable = Observable.interval(3, 2, TimeUnit.SECONDS)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread()) // 由于interval默認在新線程芽淡，所以我們應該切回主線程
.subscribe(new Consumer<Long>() {
@Override
public void accept(@NonNull Long aLong) throws Exception {
mRxOperatorsText.append("interval :" + aLong + " at " + TimeUtil.getNowStrTime() + "\n");
Log.e(TAG, "interval :" + aLong + " at " + TimeUtil.getNowStrTime() + "\n");
}
});
}
@Override
protected void onDestroy() {
super.onDestroy();
if (mDisposable != null && !mDisposable.isDisposed()) {
mDisposable.dispose();
}
}
哈哈，再次驗證豆赏，解決了我們的疑惑挣菲。
doOnNext
其實覺得 doOnNext 應該不算一個操作符，但考慮到其常用性掷邦，我們還是咬咬牙將它放在了這里白胀。它的作用是讓訂閱者在接收到數據之前干點有意思的事情。假如我們在獲取到數據之前想先保存一下它抚岗，無疑我們可以這樣實現或杠。
Observable.just(1, 2, 3, 4)
.doOnNext(new Consumer<Integer>() {
@Override
public void accept(@NonNull Integer integer) throws Exception {
mRxOperatorsText.append("doOnNext 保存 " + integer + "成功" + "\n");
Log.e(TAG, "doOnNext 保存 " + integer + "成功" + "\n");
}
}).subscribe(new Consumer<Integer>() {
@Override
public void accept(@NonNull Integer integer) throws Exception {
mRxOperatorsText.append("doOnNext :" + integer + "\n");
Log.e(TAG, "doOnNext :" + integer + "\n");
}
});
輸出：
skip
skip 很有意思，其實作用就和字面意思一樣宣蔚，接受一個 long 型參數 count 向抢，代表跳過 count 個數目開始接收。
Observable.just(1,2,3,4,5)
.skip(2)
.subscribe(new Consumer<Integer>() {
@Override
public void accept(@NonNull Integer integer) throws Exception {
mRxOperatorsText.append("skip : "+integer + "\n");
Log.e(TAG, "skip : "+integer + "\n");
}
});
輸出：
take
take胚委，接受一個 long 型參數 count 挟鸠，代表至多接收 count 個數據。
Flowable.fromArray(1,2,3,4,5)
.take(2)
.subscribe(new Consumer<Integer>() {
@Override
public void accept(@NonNull Integer integer) throws Exception {
mRxOperatorsText.append("take : "+integer + "\n");
Log.e(TAG, "accept: take : "+integer + "\n" );
}
});
輸出：
just
just篷扩，沒什么好說的兄猩，其實在前面各種例子都說明了，就是一個簡單的發(fā)射器依次調用 onNext() 方法。
Observable.just("1", "2", "3")
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Consumer<String>() {
@Override
public void accept(@NonNull String s) throws Exception {
mRxOperatorsText.append("accept : onNext : " + s + "\n");
Log.e(TAG,"accept : onNext : " + s + "\n" );
}
});
輸出：
寫在最后
好吧枢冤，本節(jié)先講到這里鸠姨，下節(jié)我們還是繼續(xù)講簡單的操作符，雖然我們的教程比較枯燥淹真，現在也不那么受人關注讶迁，但后面的系列我相信大家一定會非常喜歡的，我們下期再見核蘸！
代碼全部同步到GitHub：https://github.com/nanchen2251/RxJava2Examples
