自拍偷在线精品自拍偷,亚洲欧美中文日韩v在线观看不卡

RxJava操作符系列三（上）

作者：佚名
移動(dòng)開(kāi)發(fā) Android
在之前的文章，我們介紹了一些Observable的創(chuàng)建以及數(shù)據(jù)轉(zhuǎn)換的操作符，其中的一些數(shù)據(jù)轉(zhuǎn)換的操作符理解還是有一定的難度的，但是相信如果敲一遍代碼并且修改各種參數(shù)的值，去觀察執(zhí)行的日志，相信還是很容易的理解的。在這篇文章中，我們將介紹一些常見(jiàn)的過(guò)濾操作符，在RxJava中過(guò)濾操作符也是比較好理解的，好了，讓我們一起繼續(xù)開(kāi)啟學(xué)習(xí)之旅吧。

RxJava操作符系列傳送門

  • RxJava操作符源碼

https://github.com/xiehui999/fuseProgram

[[180583]]

前言

在之前的文章，我們介紹了一些Observable的創(chuàng)建以及數(shù)據(jù)轉(zhuǎn)換的操作符，其中的一些數(shù)據(jù)轉(zhuǎn)換的操作符理解還是有一定的難度的，但是相信如果敲一遍代碼并且修改各種參數(shù)的值，去觀察執(zhí)行的日志，相信還是很容易的理解的。在官網(wǎng)，每個(gè)操作符都給出了圖例，如果你對(duì)文字的理解不夠清楚明白，也可以去參考圖示幫助自己理解。在這篇文章中，我們將介紹一些常見(jiàn)的過(guò)濾操作符，在RxJava中過(guò)濾操作符也是比較好理解的，好了，讓我們一起繼續(xù)開(kāi)啟學(xué)習(xí)之旅吧。

Filter

該操作符接收一個(gè)Func1參數(shù)，我們可以在其中通過(guò)運(yùn)用你自己的判斷條件去判斷我們要過(guò)濾的數(shù)據(jù)，當(dāng)數(shù)據(jù)通過(guò)判斷條件后返回true表示發(fā)射該項(xiàng)數(shù)據(jù)，否則就不發(fā)射，這樣就過(guò)濾出了我們想要的數(shù)據(jù)。如下，我們過(guò)濾出不能被2整除的數(shù)

  1. Integer[] ints = {1, 2, 3, 4, 5, 6, 7, 8, 9}; 
  2.  
  3.        Observable observable = Observable.from(ints).filter(new Func1<Integer, Boolean>() { 
  4.  
  5.            @Override 
  6.  
  7.            public Boolean call(Integer integer) { 
  8.  
  9.                return integer % 2 != 0;//返回true，就不會(huì)過(guò)濾掉，會(huì)發(fā)射數(shù)據(jù)，過(guò)濾掉返回false的值 
  10.  
  11.            } 
  12.  
  13.        }); 
  14.  
  15.        Action1 action1 = new Action1<Integer>() { 
  16.  
  17.            @Override 
  18.  
  19.            public void call(Integer i) { 
  20.  
  21.                Log.e(TAG, "call: "+i ); 
  22.  
  23.            } 
  24.  
  25.        }; 
  26.  
  27.        observable.subscribe(action1);  

輸出日志信息

  1. call: 1 
  2.  
  3. call: 3 
  4.  
  5. call: 5 
  6.  
  7. call: 7 
  8.  
  9. call: 9  

ofType

該操作符是filter操作符的一個(gè)特殊形式。它過(guò)濾一個(gè)Observable只返回指定類型的數(shù)據(jù)，例如當(dāng)數(shù)據(jù)源有字符串和int型數(shù)據(jù)時(shí)，我們想要過(guò)濾出字符串就可以使用這個(gè)操作符，如下示例代碼

  1. Observable.just(0, "one", 6, 4, "two", 8, "three", 1, "four", 0) 
  2.  
  3. .ofType(String.class) 
  4.  
  5. .subscribe(new Subscriber<String>() { 
  6.  
  7. @Override 
  8.  
  9. public void onCompleted() { 
  10.  
  11. Log.e(TAG, "onCompleted:ofType "); 
  12.  
  13. } 
  14.  
  15.   
  16.  
  17. @Override 
  18.  
  19. public void onError(Throwable e) { 
  20.  
  21. Log.e(TAG, "onError:ofType "); 
  22.  
  23. } 
  24.  
  25.   
  26.  
  27. @Override 
  28.  
  29. public void onNext(String string) { 
  30.  
  31. Log.e(TAG, "onNext:ofType " + string); 
  32.  
  33. } 
  34.  
  35. });  

輸出日志信息

  1. onNext:ofType one 
  2.  
  3. onNext:ofType two 
  4.  
  5. onNext:ofType three 
  6.  
  7. onNext:ofType four 
  8.  
  9. onCompleted:ofType  

當(dāng)然除了過(guò)濾基本類型的數(shù)據(jù)，也可以過(guò)濾自定義類型數(shù)據(jù)。

First

如果我們只對(duì)Observable發(fā)射的***項(xiàng)數(shù)據(jù)，或者滿足某個(gè)條件的***項(xiàng)數(shù)據(jù)感興趣，則可以使用First操作符。

  1. Observable.just(10, 11, 12, 13).first().subscribe(new Action1() { 
  2.  
  3.             @Override 
  4.  
  5.             public void call(Integer integer) { 
  6.  
  7.                 Log.e(TAG, integer+""); 
  8.  
  9.             } 
  10.  
  11.         });  

上面日志只打印一個(gè)值10，當(dāng)然我們也可以給first傳一個(gè)參數(shù)Fun1，指定一個(gè)條件如下

  1. Observable.just(10, 11, 12, 13).first(new Func1<Integer, Boolean>() { 
  2.  
  3.             @Override 
  4.  
  5.             public Boolean call(Integer integer) { 
  6.  
  7.                 return integer > 12; 
  8.  
  9.             } 
  10.  
  11.         }).subscribe(new Action1<Integer>() { 
  12.  
  13.             @Override 
  14.  
  15.             public void call(Integer integer) { 
  16.  
  17.                 Log.e(TAG, integer+""); 
  18.  
  19.             } 
  20.  
  21.         });  

此時(shí)輸出的信息就是滿足integer > 12的***項(xiàng)數(shù)據(jù)13。

firstOrDefault

該操作符是first操作符的變形。主要是在沒(méi)有發(fā)射任何數(shù)據(jù)時(shí)發(fā)射一個(gè)你在參數(shù)中指定的默認(rèn)值。如下，它有有兩個(gè)重載方法。

  1. Observable.just(11,12,13).firstOrDefault(10).subscribe(new Action1<Object>() { 
  2.  
  3.             @Override 
  4.  
  5.             public void call(Object o) { 
  6.  
  7.                 Log.e(TAG, o.toString()); 
  8.  
  9.             } 
  10.  
  11.         });  

如果寫(xiě)成上面的代碼，這個(gè)執(zhí)行會(huì)和first效果一樣。因?yàn)闆](méi)有發(fā)射數(shù)據(jù)的時(shí)候才用到默認(rèn)值，那么我們將上面代碼更改如下，使用empty創(chuàng)建一個(gè)不發(fā)射任何數(shù)據(jù)但是正常終止的Observable。

  1. Observable.empty().firstOrDefault(10).subscribe(new Action1<Object>() { 
  2.  
  3.             @Override 
  4.  
  5.             public void call(Object o) { 
  6.  
  7.                 Log.e(TAG, o.toString()); 
  8.  
  9.             } 
  10.  
  11.         });  

發(fā)現(xiàn)此時(shí)輸出了數(shù)據(jù)10.該操作符還提供了兩個(gè)參數(shù)的重載方法firstOrDefault(T defaultValue, Func1 super T, Boolean> predicate)。我們可以增加一個(gè)條件。如下示例

  1. Observable.just(10，13,16).firstOrDefault(15, new Func1<Integer, Boolean>() { 
  2.  
  3.             @Override 
  4.  
  5.             public Boolean call(Integer integer) { 
  6.  
  7.                 return integer>20; 
  8.  
  9.             } 
  10.  
  11.         }).subscribe(new Action1<Integer>() { 
  12.  
  13.             @Override 
  14.  
  15.             public void call(Integer integer) { 
  16.  
  17.                 Log.e(TAG, ""+integer); 
  18.  
  19.             } 
  20.  
  21.         });  

此時(shí)數(shù)據(jù)源10,13,16都不滿足大于20,則此時(shí)將輸出默認(rèn)值15，如果我們將數(shù)據(jù)源數(shù)據(jù)增加一個(gè)值22.那么此時(shí)將不再輸出默認(rèn)值，而是輸出22。

takeFirst

該操作符與first操作符的區(qū)別就是如果原始Observable沒(méi)有發(fā)射任何滿足條件的數(shù)據(jù)，first會(huì)拋出一個(gè)NoSuchElementException直接執(zhí)行onError()，而takeFist會(huì)返回一個(gè)空的Observable(不調(diào)用onNext()但是會(huì)調(diào)用onCompleted)

如下面下面示例代碼 

  1. Observable.just(10,11).filter(new Func1<Integer, Boolean>() { 
  2.  
  3.             @Override 
  4.  
  5.             public Boolean call(Integer integer) { 
  6.  
  7.                 return integer>20; 
  8.  
  9.             } 
  10.  
  11.         }).first().subscribe(new Subscriber<Object>() { 
  12.  
  13.   
  14.  
  15.             @Override 
  16.  
  17.             public void onCompleted() { 
  18.  
  19.                 Log.e(TAG, "onCompleted: "); 
  20.  
  21.             } 
  22.  
  23.   
  24.  
  25.             @Override 
  26.  
  27.             public void onError(Throwable e) { 
  28.  
  29.                 Log.e(TAG, "onError: "+e.toString()); 
  30.  
  31.             } 
  32.  
  33.   
  34.  
  35.             @Override 
  36.  
  37.             public void onNext(Object o) { 
  38.  
  39.                 Log.e(TAG, "onNext: "+o.toString()); 
  40.  
  41.             } 
  42.  
  43.         });  

執(zhí)行后輸出的信息如下

  1. onError: java.util.NoSuchElementException: Sequence contains no elements 

若此時(shí)用takeFirst

  1. Observable.just(10,11).takeFirst(new Func1<Integer, Boolean>() { 
  2.  
  3.             @Override 
  4.  
  5.             public Boolean call(Integer integer) { 
  6.  
  7.                 Log.e(TAG, "call: takeFirst" ); 
  8.  
  9.                 return integer>30; 
  10.  
  11.             } 
  12.  
  13.         }).subscribe(new Subscriber<Object>() { 
  14.  
  15.   
  16.  
  17.             @Override 
  18.  
  19.             public void onCompleted() { 
  20.  
  21.                 Log.e(TAG, "onCompleted: "); 
  22.  
  23.             } 
  24.  
  25.   
  26.  
  27.             @Override 
  28.  
  29.             public void onError(Throwable e) { 
  30.  
  31.                 Log.e(TAG, "onError: "+e.toString()); 
  32.  
  33.             } 
  34.  
  35.   
  36.  
  37.             @Override 
  38.  
  39.             public void onNext(Object o) { 
  40.  
  41.                 Log.e(TAG, "onNext: "+o.toString()); 
  42.  
  43.             } 
  44.  
  45.         });  

發(fā)現(xiàn)此時(shí)不會(huì)出現(xiàn)異常，而是執(zhí)行了onCompleted()。

single

如果原始Observable在完成之前不是正好發(fā)射一次數(shù)據(jù)，它會(huì)拋出一個(gè)NoSuchElementException，白話可以理解為發(fā)送數(shù)據(jù)是一項(xiàng)的話輸出此項(xiàng)的值，若是多個(gè)數(shù)據(jù)則拋出異常執(zhí)行onError()方法。

如下代碼

  1. Observable.just(10, 11, 12, 13).single().subscribe(new Subscriber<Integer>() { 
  2.  
  3.             @Override 
  4.  
  5.             public void onCompleted() { 
  6.  
  7.                  Log.e(TAG, "onCompleted"); 
  8.  
  9.             } 
  10.  
  11.   
  12.  
  13.             @Override 
  14.  
  15.             public void onError(Throwable e) { 
  16.  
  17.                  Log.e(TAG, "onError"+e.toString()); 
  18.  
  19.             } 
  20.  
  21.   
  22.  
  23.             @Override 
  24.  
  25.             public void onNext(Integer integer) { 
  26.  
  27.                  Log.e(TAG,  integer); 
  28.  
  29.             } 
  30.  
  31.         });  

輸出信息 

  1. onError: java.util.NoSuchElementException: Sequence contains no elements 

如果將上述代碼做下簡(jiǎn)單更改

  1. Observable.just(10, 11, 12, 13).filter(new Func1<Integer, Boolean>() { 
  2.  
  3.             @Override 
  4.  
  5.             public Boolean call(Integer integer) { 
  6.  
  7.                 return integer > 12; 
  8.  
  9.             } 
  10.  
  11.         }).subscribe(new Subscriber<Integer>() { 
  12.  
  13.             @Override 
  14.  
  15.             public void onCompleted() { 
  16.  
  17.                  Log.e(TAG, "onCompleted"); 
  18.  
  19.             } 
  20.  
  21.   
  22.  
  23.             @Override 
  24.  
  25.             public void onError(Throwable e) { 
  26.  
  27.                  Log.e(TAG, "onError"+e.toString()); 
  28.  
  29.             } 
  30.  
  31.   
  32.  
  33.             @Override 
  34.  
  35.             public void onNext(Integer integer) { 
  36.  
  37.                  Log.e(TAG,  integer); 
  38.  
  39.             } 
  40.  
  41.         });  

此時(shí)會(huì)輸出數(shù)據(jù)13,因?yàn)榇藭r(shí)通過(guò)filter后就只有一條數(shù)據(jù)。single也有singleOrDefault(T)和singleOrDefault(T,Func1)兩個(gè)變體，具體可以自己代碼測(cè)試區(qū)別。

Last

該操作符與first意義相反，若我們只對(duì)Observable發(fā)射的***一項(xiàng)數(shù)據(jù)，或者滿足某個(gè)條件的***一項(xiàng)數(shù)據(jù)感興趣時(shí)使用該操作符。

示例代碼

  1. Observable.just(10, 11, 12, 13).last().subscribe(new Action1<Integer>() { 
  2.  
  3.             @Override 
  4.  
  5.             public void call(Integer integer) { 
  6.  
  7.                Log.e(TAG, "call: "+integer); 
  8.  
  9.             } 
  10.  
  11.         });  

執(zhí)行后輸出13.它有一個(gè)重載方法可以指定條件，獲取滿足條件的***一項(xiàng)數(shù)據(jù)的。將上面代碼修改如下

  1. Observable.just(10, 11, 12, 13).last(new Func1<Integer, Boolean>() { 
  2.  
  3.             @Override 
  4.  
  5.             public Boolean call(Integer integer) { 
  6.  
  7.                 return integer < 12; 
  8.  
  9.             } 
  10.  
  11.         }).subscribe(new Action1<Integer>() { 
  12.  
  13.             @Override 
  14.  
  15.             public void call(Integer integer) { 
  16.  
  17.                 Log.e(TAG, "call: "+integer); 
  18.  
  19.             } 
  20.  
  21.         });  

此時(shí)最終輸出數(shù)據(jù)就是11.該操作符和first一樣也有幾種變體，如lastOrDefault，TakeLast，具體效果可自己測(cè)試。

Skip

該操作符是跳過(guò)之前的前幾項(xiàng)數(shù)據(jù)，然后再發(fā)射數(shù)據(jù)。

  1. Observable.range(1, 10).skip(6).subscribe(new Action1<Integer>() { 
  2.  
  3.             @Override 
  4.  
  5.             public void call(Integer integer) { 
  6.  
  7.                Log.e(TAG, "call: "+integer ); 
  8.  
  9.             } 
  10.  
  11.         });  

輸出日志信息

  1. call: 7 
  2.  
  3. call: 8 
  4.  
  5. call: 9 
  6.  
  7. call: 10  

skip還有兩個(gè)重載方法.skip(long time, TimeUnit unit)默認(rèn)是在computation調(diào)度器上執(zhí)行，如果要有更新UI操作需要通過(guò)observeOn方法指定為AndroidSchedulers.mainThread()，當(dāng)然還有一個(gè)重載方法skip(long time, TimeUnit unit, Scheduler scheduler)可以指定調(diào)度器。注意的一點(diǎn)是這兩個(gè)重載方法的***個(gè)參數(shù)不是跳過(guò)的數(shù)據(jù)數(shù)量，指的是時(shí)間。

  1. Observable.interval(500, TimeUnit.MILLISECONDS) 
  2.  
  3.                 .skip(2, TimeUnit.SECONDS) 
  4.  
  5.                 .observeOn(AndroidSchedulers.mainThread()) 
  6.  
  7.                 .subscribe(new Subscriber<Long>() { 
  8.  
  9.                     @Override 
  10.  
  11.                     public void onCompleted() { 
  12.  
  13.   
  14.  
  15.                     } 
  16.  
  17.   
  18.  
  19.                     @Override 
  20.  
  21.                     public void onError(Throwable e) { 
  22.  
  23.   
  24.  
  25.                     } 
  26.  
  27.   
  28.  
  29.                     @Override 
  30.  
  31.                     public void onNext(Long aLong) { 
  32.  
  33.                         tv.append("\n" + aLong); 
  34.  
  35.                         if (aLong > 10) { 
  36.  
  37.                             this.unsubscribe(); 
  38.  
  39.                         } 
  40.  
  41.                     } 
  42.  
  43.                 });  

如上代碼，通過(guò)interval每隔500毫秒產(chǎn)生一個(gè)數(shù)據(jù)，通過(guò)skip設(shè)定跳過(guò)時(shí)間為2秒。并且當(dāng)數(shù)據(jù)大于10時(shí)解除訂閱。

skipLast

正好和skip 相反，忽略***產(chǎn)生的n個(gè)數(shù)據(jù)項(xiàng)

  1. Observable.range(1, 10).skipLast(6).subscribe(new Action1<Integer>() { 
  2.  
  3.             @Override 
  4.  
  5.             public void call(Integer integer) { 
  6.  
  7.                Log.e(TAG, "call: "+integer ); 
  8.  
  9.             } 
  10.  
  11.         });  

輸出日志信息

  1. call: 1 
  2.  
  3. call: 2 
  4.  
  5. call: 3 
  6.  
  7. call: 4  

接下文 

責(zé)任編輯：龐桂玉 來(lái)源： 安卓開(kāi)發(fā)精選
RxJava操作符Android
相關(guān)推薦

2016-12-28 09:48:09

AndroidRxJava操作符

2017-01-03 16:12:13

RxJava操作符Android

2016-12-28 09:54:50

AndroidRxJava操作符

2016-11-17 15:35:51

RxJava操作Subscriber

2009-08-19 17:26:28

C# 操作符

2010-07-14 14:55:07

Perl操作符

2021-10-31 18:59:55

Python操作符用法

2009-11-17 10:42:58

PHP操作符

2009-07-21 09:31:00

Scala操作符

2009-09-15 17:16:58

LINQ查詢操作符

2009-09-16 09:09:23

Linq Contai

2010-07-14 14:18:51

Perl操作符

2012-02-06 09:13:23

LINQ

2011-04-08 16:26:14

JavaScript

2010-07-19 11:00:24

Perl操作符

2010-07-14 14:30:31

Perl操作符

2010-01-28 11:16:28

C++操作符

2009-11-27 09:41:56

LINQ

2010-01-27 11:00:17

C++操作符

2022-10-08 07:49:55

New操作符函數(shù)
點(diǎn)贊
收藏

51CTO技術(shù)棧公眾號(hào)