正文
這可能是最好的RxJava 2.x入門教程系列專欄
文章鏈接：
這可能是最好的RxJava 2.x 入門教程（完結(jié)版）【強(qiáng)力推薦】
這可能是最好的RxJava 2.x 入門教程（一）
這可能是最好的RxJava 2.x 入門教程（二）
這可能是最好的RxJava 2.x 入門教程（三）
GitHub 代碼同步更新：https://github.com/nanchen2251/RxJava2Examples
為了滿足大家的饑渴難耐，GitHub將同步更新代碼，主要包含基本的代碼封裝，RxJava 2.x所有操作符應(yīng)用場景介紹和實(shí)際應(yīng)用場景，后期除了RxJava可能還會增添其他東西，總之，GitHub上的Demo專為大家傾心打造。傳送門：https://github.com/nanchen2251/RxJava2Examples
一、前言
年輕的老司機(jī)們，我這么勤的為大家分享，卻少有催更的，好吧。其實(shí)寫這個系列不是為了吸睛，那咱們繼續(xù)寫我們的 RxJava 2.x 的操作符。
二、正題
7、distinct
這個操作符非常的簡單、通俗、易懂，就是簡單的去重嘛，我甚至都不想貼代碼，但人嘛，總得持之以恒。
1 Observable.just(1, 1, 1, 2, 2, 3, 4, 5)2 .distinct()3 .subscribe(new Consumer<Integer>() {4 @Override5 public void accept(@NonNull Integer integer) throws Exception {6 mRxOperatorsText.append("distinct : " + integer + "\n");7 Log.e(TAG, "distinct : " + integer + "\n");8 }9 });
輸出：
Log 日志顯而易見，我們在經(jīng)過dinstinct() 后接收器接收到的事件只有1,2,3,4,5了。
8、Filter
信我，F(xiàn)ilter 你會很常用的，它的作用也很簡單，過濾器嘛?？梢越邮芤粋€參數(shù)，讓其過濾掉不符合我們條件的值
1 Observable.just(1, 20, 65, -5, 7, 19) 2 .filter(new Predicate<Integer>() { 3 @Override 4 public boolean test(@NonNull Integer integer) throws Exception { 5 return integer >= 10; 6 } 7 }).subscribe(new Consumer<Integer>() { 8 @Override 9 public void accept(@NonNull Integer integer) throws Exception {10 mRxOperatorsText.append("filter : " + integer + "\n");11 Log.e(TAG, "filter : " + integer + "\n");12 }13 });
輸出：
可以看到，我們過濾器舍去了小于10的值，所以最好的輸出只有20,65,19。
9、buffer
buffer 操作符接受兩個參數(shù)，buffef(count,skip)，作用是將 Observable 中的數(shù)據(jù)按 skip (步長) 分成最大不超過 count 的 buffer ，然后生成一個 Observable 。也許你還不太理解，我們可以通過我們的示例圖和示例代碼來進(jìn)一步深化它。
1 Observable.just(1, 2, 3, 4, 5) 2 .buffer(3, 2) 3 .subscribe(new Consumer<List<Integer>>() { 4 @Override 5 public void accept(@NonNull List<Integer> integers) throws Exception { 6 mRxOperatorsText.append("buffer size : " + integers.size() + "\n"); 7 Log.e(TAG, "buffer size : " + integers.size() + "\n"); 8 mRxOperatorsText.append("buffer value : "); 9 Log.e(TAG, "buffer value : " );10 for (Integer i : integers) {11 mRxOperatorsText.append(i + "");12 Log.e(TAG, i + "");13 }14 mRxOperatorsText.append("\n");15 Log.e(TAG, "\n");16 }17 });
輸出：
如圖，我們把1,2,3,4,5依次發(fā)射出來，經(jīng)過buffer 操作符，其中參數(shù) count 為3， skip 為2，而我們的輸出 依次是 123，345，5。顯而易見，我們 buffer 的第一個參數(shù)是count，代表最大取值，在事件足夠的時候，一般都是取count個值，然后每次跳過skip個事件。其實(shí)看 Log 日志，我相信大家都明白了。
10、timer
timer 很有意思，相當(dāng)于一個定時任務(wù)。在1.x 中它還可以執(zhí)行間隔邏輯，但在2.x中此功能被交給了 interval，下一個會介紹。但需要注意的是，timer 和 interval 均默認(rèn)在新線程。
1 mRxOperatorsText.append("timer start : " + TimeUtil.getNowStrTime() + "\n"); 2 Log.e(TAG, "timer start : " + TimeUtil.getNowStrTime() + "\n"); 3 Observable.timer(2, TimeUnit.SECONDS) 4 .subscribeOn(Schedulers.io()) 5 .observeOn(AndroidSchedulers.mainThread()) // timer 默認(rèn)在新線程，所以需要切換回主線程 6 .subscribe(new Consumer<Long>() { 7 @Override 8 public void accept(@NonNull Long aLong) throws Exception { 9 mRxOperatorsText.append("timer :" + aLong + " at " + TimeUtil.getNowStrTime() + "\n");10 Log.e(TAG, "timer :" + aLong + " at " + TimeUtil.getNowStrTime() + "\n");11 }12 });
輸出：
顯而易見，當(dāng)我們兩次點(diǎn)擊按鈕觸發(fā)這個事件的時候，接收被延遲了2秒。
11、interval
如同我們上面可說，interval 操作符用于間隔時間執(zhí)行某個操作，其接受三個參數(shù)，分別是第一次發(fā)送延遲，間隔時間，時間單位。
1 mRxOperatorsText.append("interval start : " + TimeUtil.getNowStrTime() + "\n"); 2 Log.e(TAG, "interval start : " + TimeUtil.getNowStrTime() + "\n"); 3 Observable.interval(3,2, TimeUnit.SECONDS) 4 .subscribeOn(Schedulers.io()) 5 .observeOn(AndroidSchedulers.mainThread()) // 由于interval默認(rèn)在新線程，所以我們應(yīng)該切回主線程 6 .subscribe(new Consumer<Long>() { 7 @Override 8 public void accept(@NonNull Long aLong) throws Exception { 9 mRxOperatorsText.append("interval :" + aLong + " at " + TimeUtil.getNowStrTime() + "\n");10 Log.e(TAG, "interval :" + aLong + " at " + TimeUtil.getNowStrTime() + "\n");11 }12 });
輸出：
如同 Log 日志一樣，第一次延遲了3秒后接收到，后面每次間隔了2秒。
然而，心細(xì)的小伙伴可能會發(fā)現(xiàn)，由于我們這個是間隔執(zhí)行，所以當(dāng)我們的Activity都銷毀的時候，實(shí)際上這個操作還依然在進(jìn)行，所以，我們得花點(diǎn)小心思讓我們在不需要它的時候干掉它。查看源碼發(fā)現(xiàn)，我們subscribe(Cousumer<? super T> onNext)返回的是Disposable，我們可以在這上面做文章。
1 @Override 2 protected void doSomething() { 3 mRxOperatorsText.append("interval start : " + TimeUtil.getNowStrTime() + "\n"); 4 Log.e(TAG, "interval start : " + TimeUtil.getNowStrTime() + "\n"); 5 mDisposable = Observable.interval(3, 2, TimeUnit.SECONDS) 6 .subscribeOn(Schedulers.io()) 7 .observeOn(AndroidSchedulers.mainThread()) // 由于interval默認(rèn)在新線程，所以我們應(yīng)該切回主線程 8 .subscribe(new Consumer<Long>() { 9 @Override10 public void accept(@NonNull Long aLong) throws Exception {11 mRxOperatorsText.append("interval :" + aLong + " at " + TimeUtil.getNowStrTime() + "\n");12 Log.e(TAG, "interval :" + aLong + " at " + TimeUtil.getNowStrTime() + "\n");13 }14 });15 }16 17 @Override18 protected void onDestroy() {19 super.onDestroy();20 if (mDisposable != null && !mDisposable.isDisposed()) {21 mDisposable.dispose();22 }23 }
哈哈，再次驗證，解決了我們的疑惑。
12、doOnNext
其實(shí)覺得 doOnNext 應(yīng)該不算一個操作符，但考慮到其常用性，我們還是咬咬牙將它放在了這里。它的作用是讓訂閱者在接收到數(shù)據(jù)之前干點(diǎn)有意思的事情。假如我們在獲取到數(shù)據(jù)之前想先保存一下它，無疑我們可以這樣實(shí)現(xiàn)。
1 Observable.just(1, 2, 3, 4) 2 .doOnNext(new Consumer<Integer>() { 3 @Override 4 public void accept(@NonNull Integer integer) throws Exception { 5 mRxOperatorsText.append("doOnNext 保存 " + integer + "成功" + "\n"); 6 Log.e(TAG, "doOnNext 保存 " + integer + "成功" + "\n"); 7 } 8 }).subscribe(new Consumer<Integer>() { 9 @Override10 public void accept(@NonNull Integer integer) throws Exception {11 mRxOperatorsText.append("doOnNext :" + integer + "\n");12 Log.e(TAG, "doOnNext :" + integer + "\n");13 }14 });
輸出：
13、skip
skip 很有意思，其實(shí)作用就和字面意思一樣，接受一個 long 型參數(shù) count ，代表跳過 count 個數(shù)目開始接收。
1 Observable.just(1,2,3,4,5)2 .skip(2)3 .subscribe(new Consumer<Integer>() {4 @Override5 public void accept(@NonNull Integer integer) throws Exception {6 mRxOperatorsText.append("skip : "+integer + "\n");7 Log.e(TAG, "skip : "+integer + "\n");8 }9 });
輸出：
14、take
take，接受一個 long 型參數(shù) count ，代表至多接收 count 個數(shù)據(jù)。
1 Flowable.fromArray(1,2,3,4,5)2 .take(2)3 .subscribe(new Consumer<Integer>() {4 @Override5 public void accept(@NonNull Integer integer) throws Exception {6 mRxOperatorsText.append("take : "+integer + "\n");7 Log.e(TAG, "accept: take : "+integer + "\n" );8 }9 });
輸出：
15、just
just，沒什么好說的，其實(shí)在前面各種例子都說明了，就是一個簡單的發(fā)射器依次調(diào)用onNext()方法。
1 Observable.just("1", "2", "3") 2 .subscribeOn(Schedulers.io()) 3 .observeOn(AndroidSchedulers.mainThread()) 4 .subscribe(new Consumer<String>() { 5 @Override 6 public void accept(@NonNull String s) throws Exception { 7 mRxOperatorsText.append("accept : onNext : " + s + "\n"); 8 Log.e(TAG,"accept : onNext : " + s + "\n" ); 9 }10 });
輸出：
三、寫在最后
好吧，本節(jié)先講到這里，下節(jié)我們還是繼續(xù)講簡單的操作符，雖然我們的教程比較枯燥，現(xiàn)在也不那么受人關(guān)注，但后面的系列我相信大家一定會非常喜歡的，我們下期再見！
代碼全部同步到GitHub：https://github.com/nanchen2251/RxJava2Examples
作 者： 南 塵 
出 處： http://www.cnblogs.com/liushilin/
關(guān)于作者：專注于移動前端的項目開發(fā)。如有問題或建議，請多多賜教！歡迎加入Android交流群：118116509
版權(quán)聲明：本文版權(quán)歸作者和博客園共有，歡迎轉(zhuǎn)載，但未經(jīng)作者同意必須保留此段聲明，且在文章頁面明顯位置給出原文鏈接。
特此聲明：所有評論和私信都會在第一時間回復(fù)。也歡迎園子的大大們指正錯誤，共同進(jìn)步?；蛘?a style="margin: 0px; padding: 0px; color: rgb(0, 0, 0); text-decoration-line: none;">直接私信我
聲援博主：如果您覺得文章對您有幫助，可以點(diǎn)擊文章下部【推薦】或側(cè)邊【關(guān)注】。您的鼓勵是作者堅持原創(chuàng)和持續(xù)寫作的最大動力！
http://www.cnblogs.com/liushilin/p/7069617.html
延伸閱讀
- Unreal Engine 4（虛幻UE4）GameplayAbilities 插件入門教程（三）技能標(biāo)簽（Ability Tags） 2017-07-25
- 【知識整理】這可能是最好的RxJava 2.x 教程（完結(jié)版） 2017-07-21
- 【知識整理】這可能是最好的RxJava 2.x 入門教程（二） 2017-07-06
- 【知識整理】這可能是最好的RxJava 2.x 入門教程（五） 2017-07-03
- 【知識整理】這可能是最好的RxJava 2.x 入門教程（一） 2017-06-21
Unreal Engine 4（虛幻UE4）GameplayAbilities 插件入門教程（三）技能標(biāo)簽（Ability Tags）