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

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

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營(yíng)銷解決方案
RxJava中操作符到底做了什么？

RxJava今年徹底火了一把，其中最牛逼之處就是操作符了，以前只知道怎么用，這幾天看了看源碼，大致的弄清楚了操作符的工作過(guò)程，今天分享給大家。如果有什么不對(duì)地方，請(qǐng)大家多多指教。

目前累計(jì)服務(wù)客戶上千余家，積累了豐富的產(chǎn)品開發(fā)及服務(wù)經(jīng)驗(yàn)。以網(wǎng)站設(shè)計(jì)水平和技術(shù)實(shí)力，樹立企業(yè)形象，為客戶提供成都網(wǎng)站制作、做網(wǎng)站、外貿(mào)營(yíng)銷網(wǎng)站建設(shè)、網(wǎng)站策劃、網(wǎng)頁(yè)設(shè)計(jì)、網(wǎng)絡(luò)營(yíng)銷、VI設(shè)計(jì)、網(wǎng)站改版、漏洞修補(bǔ)等服務(wù)。成都創(chuàng)新互聯(lián)始終以務(wù)實(shí)、誠(chéng)信為根本，不斷創(chuàng)新和提高建站品質(zhì)，通過(guò)對(duì)領(lǐng)先技術(shù)的掌握、對(duì)創(chuàng)意設(shè)計(jì)的研究、對(duì)客戶形象的視覺(jué)傳遞、對(duì)應(yīng)用系統(tǒng)的結(jié)合，為客戶提供更好的一站式互聯(lián)網(wǎng)解決方案，攜手廣大客戶，共同發(fā)展進(jìn)步。

今天我們已filter為例，看代碼：

 
 
    
  
  
  1. Integer[] datas={1,2,3,4,5,6,7,8,9,10};
    2. 
  
  
  2. Observable.from(datas)
    3. 
  
  
  3.         .filter(new Func1() {
    4. 
  
  
  4.             @Override
    5. 
  
  
  5.             public Boolean call(Integer integer) {
    6. 
  
  
  6.                 return integer>=5;
    7. 
  
  
  7.             }
    8. 
  
  
  8.         })
    9. 
  
  
  9.         .subscribe(new Action1() {
    10. 
  
  
  10.             @Override
    11. 
  
  
  11.             public void call(Integer integer) {
    12. 
  
  
  12.                 mText.append(integer.toString()+",");
    13. 
  
  
  13.             }
    14. 
  
  
  14.         });
    15.

一個(gè)很簡(jiǎn)單的小例子，用過(guò)濾操作符 filter 找出大于等于5的數(shù)字。我們點(diǎn)進(jìn)去看看源碼中filter做了什么

 
 
    
  
  
  1. public final Observable filter(Func1 predicate) { 
    2. 
  
  
  2. return create(new OnSubscribeFilter(this, predicate)); 
    3. 
  
  
  3. }
    4.

調(diào)用了create()方法，等等我們什么時(shí)候是不是也用過(guò)create() 方法，我們?cè)趧?chuàng)建Observable時(shí)候也用過(guò)create()方法，原來(lái)創(chuàng)建了一個(gè)新的Observable返回出去了，那豈不是說(shuō)我們的訂閱者其實(shí)訂閱的是這個(gè)新的Observable，我們繼續(xù)往下看create方法，create方法需要的參數(shù)是一個(gè)OnSubscribe對(duì)象，那我們可以確定OnSubscribeFilter是OnSubscribe的一個(gè)實(shí)現(xiàn)類，我們點(diǎn)進(jìn)去看看。

 
 
    
  
  
  1. public final class OnSubscribeFilter implements OnSubscribe {
    2. 
  
  
  2.    
    3. 
  
  
  3.        final Observable source;
    4. 
  
  
  4.    
    5. 
  
  
  5.        final Func1 predicate;
    6. 
  
  
  6.    
    7. 
  
  
  7.        public OnSubscribeFilter(Observable source, Func1 predicate) {
    8. 
  
  
  8.            this.source = source;
    9. 
  
  
  9.            this.predicate = predicate;
    10. 
  
  
  10.        }
    11.

果然不出我們所料，OnSubscribeFilter是OnSubscribe的實(shí)現(xiàn)類，我們看他的構(gòu)造方法，傳遞了兩個(gè)參數(shù)，第一個(gè)參數(shù)Observable對(duì)象，一個(gè)Func1，其中第一個(gè)參數(shù)就是我們我們自己創(chuàng)建的那個(gè)Observable，第二個(gè)參數(shù)使我們?cè)谕饷鎸懙腇unc1，然后保存了起來(lái)。我們都知道在subscribe()訂閱的時(shí)候，OnSubscribe的call()方法。我們看看OnSubscribeFilter的call()方法都干了些什么

 
 
    
  
  
  1. @Override
    2. 
  
  
  2.         public void call(final Subscriber child) {
    3. 
  
  
  3.             FilterSubscriber parent = new FilterSubscriber(child, predicate);
    4. 
  
  
  4.             child.add(parent);
    5. 
  
  
  5.             source.unsafeSubscribe(parent);
    6. 
  
  
  6.         }
    7.

出現(xiàn)了一個(gè)FilterSubscriber，什么鬼玩意兒，我們看看他是什么鬼

 
 
    
  
  
  1. }
    2. 
  
  
  2. 
  
  
  3.       @Override
    4. 
  
  
  4.       public void onError(Throwable e) {
    5. 
  
  
  5.           if (done) {
    6. 
  
  
  6.               RxJavaHooks.onError(e);
    7. 
  
  
  7.               return;
    8. 
  
  
  8.           }
    9. 
  
  
  9.           done = true;
    10. 
  
  
  10. 
  
  
  11.           actual.onError(e);
    12. 
  
  
  12.       }
    13. 
  
  
  13. 
  
  
  14. 
  
  
  15.       @Override
    16. 
  
  
  16.       public void onCompleted() {
    17. 
  
  
  17.           if (done) {
    18. 
  
  
  18.               return;
    19. 
  
  
  19.           }
    20. 
  
  
  20.           actual.onCompleted();
    21. 
  
  
  21.       }
    22. 
  
  
  22.       @Override
    23. 
  
  
  23.       public void setProducer(Producer p) {
    24. 
  
  
  24.           super.setProducer(p);
    25. 
  
  
  25.           actual.setProducer(p);
    26. 
  
  
  26.       }
    27. 
  
  
  27.   }
    28.

一個(gè)Subscriber的子類，我們看他的構(gòu)造方法，兩個(gè)參數(shù)，一個(gè)Subscriber一個(gè)Func1，我們?cè)趧?chuàng)建對(duì)象時(shí)候Subscriber對(duì)象是我們真正的從外界傳過(guò)來(lái)的觀察者，F(xiàn)unc1呢使我們創(chuàng)建OnSubscribeFilter時(shí)候傳遞進(jìn)來(lái)的對(duì)象，也就是我們?cè)谕饨缍x的Func1。

回過(guò)頭來(lái)我們繼續(xù)看OnSubscribeFilter的call方法。我們看到source.unsafeSubscribe(parent)，source是我們?cè)瓉?lái)外界的Observable,他訂閱了FilterSubscriber對(duì)象。我們?cè)谒膐nNext方法中看到他根據(jù)func1.call(t)的返回值來(lái)判斷是否讓我們外界的真正的觀察者調(diào)用onNext方法。

看到這里有沒(méi)有恍然大悟，啥?我都不知道你在說(shuō)啥，額，那我們整體的屢屢。

我們外界的代碼，在subscribe()時(shí)候，Subscriber并不是訂閱了我們自己寫的Observable，Subscriber訂閱的是filter方法返回的那個(gè)新的Observable對(duì)象，所以訂閱時(shí)候會(huì)調(diào)用OnSubscribeFilter的call方法，OnSubscribeFilter才是我們訂閱的被觀察者的onSubscribe對(duì)象，在OnSubscribeFilter的call()方法中，我們讓我們包裝的FilterSubscriber訂閱我們?cè)瓉?lái)的被觀察者，也就是我們?cè)谕饨缟傻哪莻€(gè)Observable。我們?cè)谕饨绲腛bservable的onSubscribe對(duì)象的call方法中得到的觀察者是FilterSubscriber對(duì)象，我們調(diào)用的onNext會(huì)回調(diào)到FilterSubscriber的onNext方法中。在FilterSubscriber的onNext方法中我們根據(jù)我們傳遞的Func1來(lái)判斷是否要回調(diào)真正的Subscriber的onNext方法，在為true的時(shí)候我們才回調(diào)我們外界的觀察者的onNext方法，也就起到了過(guò)濾的作用。這就是Filter的整個(gè)的流程。

我們來(lái)測(cè)試下我們的小結(jié)論：

 
 
    
  
  
  1. Observable.create(new Observable.OnSubscribe() {
    2. 
  
  
  2.                @Override
    3. 
  
  
  3.                public void call(Subscriber subscriber) {
    4. 
  
  
  4.                    Log.e("call:subscriber", "" + subscriber.getClass().getCanonicalName());
    5. 
  
  
  5.                    subscriber.onNext(5);
    6. 
  
  
  6.                }
    7. 
  
  
  7.            }).filter(new Func1() {
    8. 
  
  
  8.                @Override
    9. 
  
  
  9.                public Boolean call(Integer integer) {
    10. 
  
  
  10.                    return integer > 0;
    11. 
  
  
  11.                }
    12. 
  
  
  12.            }).subscribe(new Action1() {
    13. 
  
  
  13.                @Override
    14. 
  
  
  14.                public void call(Integer integer) {
    15. 
  
  
  15.                    
    16. 
  
  
  16.                }
    17. 
  
  
  17.            });
    18.

分享標(biāo)題：RxJava中操作符到底做了什么？
標(biāo)題鏈接：http://m.5511xx.com/article/cciegeo.html