日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

RELATEED CONSULTING
相關咨詢
選擇下列產(chǎn)品馬上在線溝通
服務時間：8:30-17:00
你可能遇到了下面的問題
關閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
RxJava操作符系列三（上）

RxJava操作符系列傳送門

網(wǎng)站建設哪家好，找成都創(chuàng)新互聯(lián)！專注于網(wǎng)頁設計、網(wǎng)站建設、微信開發(fā)、微信小程序、集團企業(yè)網(wǎng)站建設等服務項目。為回饋新老客戶創(chuàng)新互聯(lián)還提供了吉木薩爾免費建站歡迎大家使用！

  • RxJava操作符源碼

https://github.com/xiehui999/fuseProgram

  • RxJava操作符系列一
  • RxJava操作符系列二

前言

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

Filter

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

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

輸出日志信息

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

ofType

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

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

輸出日志信息

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

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

First

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

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

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

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

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

firstOrDefault

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

 
 
 
    
  
  
  
  1. Observable.just(11,12,13).firstOrDefault(10).subscribe(new Action1() { 
  
  
  
  2.  
    3. 
  
  
  
  3.             @Override 
    4. 
  
  
  
  4.  
    5. 
  
  
  
  5.             public void call(Object o) { 
    6. 
  
  
  
  6.  
    7. 
  
  
  
  7.                 Log.e(TAG, o.toString()); 
    8. 
  
  
  
  8.  
    9. 
  
  
  
  9.             } 
    10. 
  
  
  
  10.  
    11. 
  
  
  
  11.         });  
    12. 
 
 
 
    如果寫成上面的代碼，這個執(zhí)行會和first效果一樣。因為沒有發(fā)射數(shù)據(jù)的時候才用到默認值，那么我們將上面代碼更改如下，使用empty創(chuàng)建一個不發(fā)射任何數(shù)據(jù)但是正常終止的Observable。
     
 
 
      
  
  
  
    1. Observable.empty().firstOrDefault(10).subscribe(new Action1() { 
  
  
  
    2.  
      3. 
  
  
  
    3.             @Override 
      4. 
  
  
  
    4.  
      5. 
  
  
  
    5.             public void call(Object o) { 
      6. 
  
  
  
    6.  
      7. 
  
  
  
    7.                 Log.e(TAG, o.toString()); 
      8. 
  
  
  
    8.  
      9. 
  
  
  
    9.             } 
      10. 
  
  
  
    10.  
      11. 
  
  
  
    11.         });  
      12. 
 
 
 
      發(fā)現(xiàn)此時輸出了數(shù)據(jù)10.該操作符還提供了兩個參數(shù)的重載方法firstOrDefault(T defaultValue, Func1 super T, Boolean> predicate)。我們可以增加一個條件。如下示例
       
 
 
        
  
  
  
      1. Observable.just(10，13,16).firstOrDefault(15, new Func1() { 
        2. 
  
  
  
      2.  
        3. 
  
  
  
      3.             @Override 
        4. 
  
  
  
      4.  
        5. 
  
  
  
      5.             public Boolean call(Integer integer) { 
        6. 
  
  
  
      6.  
        7. 
  
  
  
      7.                 return integer>20; 
        8. 
  
  
  
      8.  
        9. 
  
  
  
      9.             } 
        10. 
  
  
  
      10.  
        11. 
  
  
  
      11.         }).subscribe(new Action1() { 
        12. 
  
  
  
      12.  
        13. 
  
  
  
      13.             @Override 
        14. 
  
  
  
      14.  
        15. 
  
  
  
      15.             public void call(Integer integer) { 
        16. 
  
  
  
      16.  
        17. 
  
  
  
      17.                 Log.e(TAG, ""+integer); 
        18. 
  
  
  
      18.  
        19. 
  
  
  
      19.             } 
        20. 
  
  
  
      20.  
        21. 
  
  
  
      21.         });  
        22. 
 
 
 
      此時數(shù)據(jù)源10,13,16都不滿足大于20,則此時將輸出默認值15，如果我們將數(shù)據(jù)源數(shù)據(jù)增加一個值22.那么此時將不再輸出默認值，而是輸出22。
      takeFirst
      該操作符與first操作符的區(qū)別就是如果原始Observable沒有發(fā)射任何滿足條件的數(shù)據(jù)，first會拋出一個NoSuchElementException直接執(zhí)行onError()，而takeFist會返回一個空的Observable(不調(diào)用onNext()但是會調(diào)用onCompleted)
      如下面下面示例代碼 
       
 
 
        
  
  
  
      1. Observable.just(10,11).filter(new Func1() { 
        2. 
  
  
  
      2.  
        3. 
  
  
  
      3.             @Override 
        4. 
  
  
  
      4.  
        5. 
  
  
  
      5.             public Boolean call(Integer integer) { 
        6. 
  
  
  
      6.  
        7. 
  
  
  
      7.                 return integer>20; 
        8. 
  
  
  
      8.  
        9. 
  
  
  
      9.             } 
        10. 
  
  
  
      10.  
        11. 
  
  
  
      11.         }).first().subscribe(new Subscriber() { 
  
  
  
      12.  
        13. 
  
  
  
      13.   
        14. 
  
  
  
      14.  
        15. 
  
  
  
      15.             @Override 
        16. 
  
  
  
      16.  
        17. 
  
  
  
      17.             public void onCompleted() { 
        18. 
  
  
  
      18.  
        19. 
  
  
  
      19.                 Log.e(TAG, "onCompleted: "); 
        20. 
  
  
  
      20.  
        21. 
  
  
  
      21.             } 
        22. 
  
  
  
      22.  
        23. 
  
  
  
      23.   
        24. 
  
  
  
      24.  
        25. 
  
  
  
      25.             @Override 
        26. 
  
  
  
      26.  
        27. 
  
  
  
      27.             public void onError(Throwable e) { 
        28. 
  
  
  
      28.  
        29. 
  
  
  
      29.                 Log.e(TAG, "onError: "+e.toString()); 
        30. 
  
  
  
      30.  
        31. 
  
  
  
      31.             } 
        32. 
  
  
  
      32.  
        33. 
  
  
  
      33.   
        34. 
  
  
  
      34.  
        35. 
  
  
  
      35.             @Override 
        36. 
  
  
  
      36.  
        37. 
  
  
  
      37.             public void onNext(Object o) { 
        38. 
  
  
  
      38.  
        39. 
  
  
  
      39.                 Log.e(TAG, "onNext: "+o.toString()); 
        40. 
  
  
  
      40.  
        41. 
  
  
  
      41.             } 
        42. 
  
  
  
      42.  
        43. 
  
  
  
      43.         });  
        44. 
 
 
 
        執(zhí)行后輸出的信息如下
         
 
 
          
  
  
  
        1. onError: java.util.NoSuchElementException: Sequence contains no elements 
          2. 
 
 
 
        若此時用takeFirst
         
 
 
          
  
  
  
        1. Observable.just(10,11).takeFirst(new Func1() { 
          2. 
  
  
  
        2.  
          3. 
  
  
  
        3.             @Override 
          4. 
  
  
  
        4.  
          5. 
  
  
  
        5.             public Boolean call(Integer integer) { 
          6. 
  
  
  
        6.  
          7. 
  
  
  
        7.                 Log.e(TAG, "call: takeFirst" ); 
          8. 
  
  
  
        8.  
          9. 
  
  
  
        9.                 return integer>30; 
          10. 
  
  
  
        10.  
          11. 
  
  
  
        11.             } 
          12. 
  
  
  
        12.  
          13. 
  
  
  
        13.         }).subscribe(new Subscriber() { 
  
  
  
        14.  
          15. 
  
  
  
        15.   
          16. 
  
  
  
        16.  
          17. 
  
  
  
        17.             @Override 
          18. 
  
  
  
        18.  
          19. 
  
  
  
        19.             public void onCompleted() { 
          20. 
  
  
  
        20.  
          21. 
  
  
  
        21.                 Log.e(TAG, "onCompleted: "); 
          22. 
  
  
  
        22.  
          23. 
  
  
  
        23.             } 
          24. 
  
  
  
        24.  
          25. 
  
  
  
        25.   
          26. 
  
  
  
        26.  
          27. 
  
  
  
        27.             @Override 
          28. 
  
  
  
        28.  
          29. 
  
  
  
        29.             public void onError(Throwable e) { 
          30. 
  
  
  
        30.  
          31. 
  
  
  
        31.                 Log.e(TAG, "onError: "+e.toString()); 
          32. 
  
  
  
        32.  
          33. 
  
  
  
        33.             } 
          34. 
  
  
  
        34.  
          35. 
  
  
  
        35.   
          36. 
  
  
  
        36.  
          37. 
  
  
  
        37.             @Override 
          38. 
  
  
  
        38.  
          39. 
  
  
  
        39.             public void onNext(Object o) { 
          40. 
  
  
  
        40.  
          41. 
  
  
  
        41.                 Log.e(TAG, "onNext: "+o.toString()); 
          42. 
  
  
  
        42.  
          43. 
  
  
  
        43.             } 
          44. 
  
  
  
        44.  
          45. 
  
  
  
        45.         });  
          46. 
 
 
 
          發(fā)現(xiàn)此時不會出現(xiàn)異常，而是執(zhí)行了onCompleted()。
          single
          如果原始Observable在完成之前不是正好發(fā)射一次數(shù)據(jù)，它會拋出一個NoSuchElementException，白話可以理解為發(fā)送數(shù)據(jù)是一項的話輸出此項的值，若是多個數(shù)據(jù)則拋出異常執(zhí)行onError()方法。
          如下代碼
           
 
 
            
  
  
  
          1. Observable.just(10, 11, 12, 13).single().subscribe(new Subscriber() { 
            2. 
  
  
  
          2.  
            3. 
  
  
  
          3.             @Override 
            4. 
  
  
  
          4.  
            5. 
  
  
  
          5.             public void onCompleted() { 
            6. 
  
  
  
          6.  
            7. 
  
  
  
          7.                  Log.e(TAG, "onCompleted"); 
            8. 
  
  
  
          8.  
            9. 
  
  
  
          9.             } 
            10. 
  
  
  
          10.  
            11. 
  
  
  
          11.   
            12. 
  
  
  
          12.  
            13. 
  
  
  
          13.             @Override 
            14. 
  
  
  
          14.  
            15. 
  
  
  
          15.             public void onError(Throwable e) { 
            16. 
  
  
  
          16.  
            17. 
  
  
  
          17.                  Log.e(TAG, "onError"+e.toString()); 
            18. 
  
  
  
          18.  
            19. 
  
  
  
          19.             } 
            20. 
  
  
  
          20.  
            21. 
  
  
  
          21.   
            22. 
  
  
  
          22.  
            23. 
  
  
  
          23.             @Override 
            24. 
  
  
  
          24.  
            25. 
  
  
  
          25.             public void onNext(Integer integer) { 
            26. 
  
  
  
          26.  
            27. 
  
  
  
          27.                  Log.e(TAG,  integer); 
            28. 
  
  
  
          28.  
            29. 
  
  
  
          29.             } 
            30. 
  
  
  
          30.  
            31. 
  
  
  
          31.         });  
            32. 
 
 
 
          輸出信息 
           
 
 
            
  
  
  
          1. onError: java.util.NoSuchElementException: Sequence contains no elements 
            2. 
 
 
 
          如果將上述代碼做下簡單更改
           
 
 
            
  
  
  
          1. Observable.just(10, 11, 12, 13).filter(new Func1() { 
            2. 
  
  
  
          2.  
            3. 
  
  
  
          3.             @Override 
            4. 
  
  
  
          4.  
            5. 
  
  
  
          5.             public Boolean call(Integer integer) { 
            6. 
  
  
  
          6.  
            7. 
  
  
  
          7.                 return integer > 12; 
            8. 
  
  
  
          8.  
            9. 
  
  
  
          9.             } 
            10. 
  
  
  
          10.  
            11. 
  
  
  
          11.         }).subscribe(new Subscriber() { 
            12. 
  
  
  
          12.  
            13. 
  
  
  
          13.             @Override 
            14. 
  
  
  
          14.  
            15. 
  
  
  
          15.             public void onCompleted() { 
            16. 
  
  
  
          16.  
            17. 
  
  
  
          17.                  Log.e(TAG, "onCompleted"); 
            18. 
  
  
  
          18.  
            19. 
  
  
  
          19.             } 
            20. 
  
  
  
          20.  
            21. 
  
  
  
          21.   
            22. 
  
  
  
          22.  
            23. 
  
  
  
          23.             @Override 
            24. 
  
  
  
          24.  
            25. 
  
  
  
          25.             public void onError(Throwable e) { 
            26. 
  
  
  
          26.  
            27. 
  
  
  
          27.                  Log.e(TAG, "onError"+e.toString()); 
            28. 
  
  
  
          28.  
            29. 
  
  
  
          29.             } 
            30. 
  
  
  
          30.  
            31. 
  
  
  
          31.   
            32. 
  
  
  
          32.  
            33. 
  
  
  
          33.             @Override 
            34. 
  
  
  
          34.  
            35. 
  
  
  
          35.             public void onNext(Integer integer) { 
            36. 
  
  
  
          36.  
            37. 
  
  
  
          37.                  Log.e(TAG,  integer); 
            38. 
  
  
  
          38.  
            39. 
  
  
  
          39.             } 
            40. 
  
  
  
          40.  
            41. 
  
  
  
          41.         });  
            42. 
 
 
 
          此時會輸出數(shù)據(jù)13,因為此時通過filter后就只有一條數(shù)據(jù)。single也有singleOrDefault(T)和singleOrDefault(T,Func1)兩個變體，具體可以自己代碼測試區(qū)別。
          Last
          該操作符與first意義相反，若我們只對Observable發(fā)射的***一項數(shù)據(jù)，或者滿足某個條件的***一項數(shù)據(jù)感興趣時使用該操作符。
          示例代碼
           
 
 
            
  
  
  
          1. Observable.just(10, 11, 12, 13).last().subscribe(new Action1() { 
            2. 
  
  
  
          2.  
            3. 
  
  
  
          3.             @Override 
            4. 
  
  
  
          4.  
            5. 
  
  
  
          5.             public void call(Integer integer) { 
            6. 
  
  
  
          6.  
            7. 
  
  
  
          7.                Log.e(TAG, "call: "+integer); 
            8. 
  
  
  
          8.  
            9. 
  
  
  
          9.             } 
            10. 
  
  
  
          10.  
            11. 
  
  
  
          11.         });  
            12. 
 
 
 
          執(zhí)行后輸出13.它有一個重載方法可以指定條件，獲取滿足條件的***一項數(shù)據(jù)的。將上面代碼修改如下
           
 
 
            
  
  
  
          1. Observable.just(10, 11, 12, 13).last(new Func1() { 
            2. 
  
  
  
          2.  
            3. 
  
  
  
          3.             @Override 
            4. 
  
  
  
          4.  
            5. 
  
  
  
          5.             public Boolean call(Integer integer) { 
            6. 
  
  
  
          6.  
            7. 
  
  
  
          7.                 return integer < 12; 
            8. 
  
  
  
          8.  
            9. 
  
  
  
          9.             } 
            10. 
  
  
  
          10.  
            11. 
  
  
  
          11.         }).subscribe(new Action1() { 
            12. 
  
  
  
          12.  
            13. 
  
  
  
          13.             @Override 
            14. 
  
  
  
          14.  
            15. 
  
  
  
          15.             public void call(Integer integer) { 
            16. 
  
  
  
          16.  
            17. 
  
  
  
          17.                 Log.e(TAG, "call: "+integer); 
            18. 
  
  
  
          18.  
            19. 
  
  
  
          19.             } 
            20. 
  
  
  
          20.  
            21. 
  
  
  
          21.         });  
            22. 
 
 
 
          此時最終輸出數(shù)據(jù)就是11.該操作符和first一樣也有幾種變體，如lastOrDefault，TakeLast，具體效果可自己測試。
          Skip
          該操作符是跳過之前的前幾項數(shù)據(jù)，然后再發(fā)射數(shù)據(jù)。
           
 
 
            
  
  
  
          1. Observable.range(1, 10).skip(6).subscribe(new Action1() { 
            2. 
  
  
  
          2.  
            3. 
  
  
  
          3.             @Override 
            4. 
  
  
  
          4.  
            5. 
  
  
  
          5.             public void call(Integer integer) { 
            6. 
  
  
  
          6.  
            7. 
  
  
  
          7.                Log.e(TAG, "call: "+integer ); 
            8. 
  
  
  
          8.  
            9. 
  
  
  
          9.             } 
            10. 
  
  
  
          10.  
            11. 
  
  
  
          11.         });  
            12. 
 
 
 
          輸出日志信息
           
 
 
            
  
  
  
          1. call: 7 
            2. 
  
  
  
          2.  
            3. 
  
  
  
          3. call: 8 
            4. 
  
  
  
          4.  
            5. 
  
  
  
          5. call: 9 
            6. 
  
  
  
          6.  
            7. 
  
  
  
          7. call: 10  
            8. 
 
 
 
          skip還有兩個重載方法.skip(long time, TimeUnit unit)默認是在computation調(diào)度器上執(zhí)行，如果要有更新UI操作需要通過observeOn方法指定為AndroidSchedulers.mainThread()，當然還有一個重載方法skip(long time, TimeUnit unit, Scheduler scheduler)可以指定調(diào)度器。注意的一點是這兩個重載方法的***個參數(shù)不是跳過的數(shù)據(jù)數(shù)量，指的是時間。
           
 
 
            
  
  
  
          1. Observable.interval(500, TimeUnit.MILLISECONDS) 
            2. 
  
  
  
          2.  
            3. 
  
  
  
          3.                 .skip(2, TimeUnit.SECONDS) 
            4. 
  
  
  
          4.  
            5. 
  
  
  
          5.                 .observeOn(AndroidSchedulers.mainThread()) 
            6. 
  
  
  
          6.  
            7. 
  
  
  
          7.                 .subscribe(new Subscriber() { 
            8. 
  
  
  
          8.  
            9. 
  
  
  
          9.                     @Override 
            10. 
  
  
  
          10.  
            11. 
  
  
  
          11.                     public void onCompleted() { 
            12. 
  
  
  
          12.  
            13. 
  
  
  
          13.   
            14. 
  
  
  
          14.  
            15. 
  
  
  
          15.                     } 
            16. 
  
  
  
          16.  
            17. 
  
  
  
          17.   
            18. 
  
  
  
          18.  
            19. 
  
  
  
          19.                     @Override 
            20. 
  
  
  
          20.  
            21. 
  
  
  
          21.                     public void onError(Throwable e) { 
            22. 
  
  
  
          22.  
            23. 
  
  
  
          23.   
            24. 
  
  
  
          24.  
            25. 
  
  
  
          25.                     } 
            26. 
  
  
  
          26.  
            27. 
  
  
  
          27.   
            28. 
  
  
  
          28.  
            29. 
  
  
  
          29.                     @Override 
            30. 
  
  
  
          30.  
            31. 
  
  
  
          31.                     public void onNext(Long aLong) { 
            32. 
  
  
  
          32.  
            33. 
  
  
  
          33.                         tv.append("\n" + aLong); 
            34. 
  
  
  
          34.  
            35. 
  
  
  
          35.                         if (aLong > 10) { 
            36. 
  
  
  
          36.  
            37. 
  
  
  
          37.                             this.unsubscribe(); 
            38. 
  
  
  
          38.  
            39. 
  
  
  
          39.                         } 
            40. 
  
  
  
          40.  
            41. 
  
  
  
          41.                     } 
            42. 
  
  
  
          42.  
            43. 
  
  
  
          43.                 });  
            44. 
 
 
 
          如上代碼，通過interval每隔500毫秒產(chǎn)生一個數(shù)據(jù)，通過skip設定跳過時間為2秒。并且當數(shù)據(jù)大于10時解除訂閱。
          skipLast
          正好和skip 相反，忽略***產(chǎn)生的n個數(shù)據(jù)項
           
 
 
            
  
  
  
          1. Observable.range(1, 10).skipLast(6).subscribe(new Action1() { 
            2. 
  
  
  
          2.  
            3. 
  
  
  
          3.             @Override 
            4. 
  
  
  
          4.  
            5. 
  
  
  
          5.             public void call(Integer integer) { 
            6. 
  
  
  
          6.  
            7. 
  
  
  
          7.                Log.e(TAG, "call: "+integer ); 
            8. 
  
  
  
          8.  
            9. 
  
  
  
          9.             } 
            10. 
  
  
  
          10.  
            11. 
  
  
  
          11.         });  
            12. 
 
 
 
          輸出日志信息
           
 
 
            
  
  
  
          1. call: 1 
            2. 
  
  
  
          2.  
            3. 
  
  
  
          3. call: 2 
            4. 
  
  
  
          4.  
            5. 
  
  
  
          5. call: 3 
            6. 
  
  
  
          6.  
            7. 
  
  
  
          7. call: 4  
            8. 
 
 
 
          接下文 
                                                          
          
                                                網(wǎng)站標題：RxJava操作符系列三（上）                                                
          
                                                當前鏈接：http://m.5511xx.com/article/dhdeigg.html