性爱有声小说在线收听,欢乐颂

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案

RxJava中操作符到底做了什么？

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

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

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

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

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

 
 
  
  public final Observable filter(Func1 predicate) { 
  
  return create(new OnSubscribeFilter(this, predicate)); 
  
  }

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

 
 
  
  public final class OnSubscribeFilter implements OnSubscribe {
  
     
  
         final Observable source;
  
     
  
         final Func1 predicate;
  
     
  
         public OnSubscribeFilter(Observable source, Func1 predicate) {
  
             this.source = source;
  
             this.predicate = predicate;
  
         }

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

 
 
  
  @Override
  
          public void call(final Subscriber child) {
  
              FilterSubscriber parent = new FilterSubscriber(child, predicate);
  
              child.add(parent);
  
              source.unsafeSubscribe(parent);
  
          }

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

 
 
  
  }
  
  
  
        @Override
  
        public void onError(Throwable e) {
  
            if (done) {
  
                RxJavaHooks.onError(e);
  
                return;
  
            }
  
            done = true;
  
  
  
            actual.onError(e);
  
        }
  
  
  
  
  
        @Override
  
        public void onCompleted() {
  
            if (done) {
  
                return;
  
            }
  
            actual.onCompleted();
  
        }
  
        @Override
  
        public void setProducer(Producer p) {
  
            super.setProducer(p);
  
            actual.setProducer(p);
  
        }
  
    }

一個Subscriber的子類，我們看他的構(gòu)造方法，兩個參數(shù)，一個Subscriber一個Func1，我們在創(chuàng)建對象時候Subscriber對象是我們真正的從外界傳過來的觀察者，F(xiàn)unc1呢使我們創(chuàng)建OnSubscribeFilter時候傳遞進來的對象，也就是我們在外界定義的Func1。

回過頭來我們繼續(xù)看OnSubscribeFilter的call方法。我們看到source.unsafeSubscribe(parent)，source是我們原來外界的Observable,他訂閱了FilterSubscriber對象。我們在他的onNext方法中看到他根據(jù)func1.call(t)的返回值來判斷是否讓我們外界的真正的觀察者調(diào)用onNext方法。

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

我們外界的代碼，在subscribe()時候，Subscriber并不是訂閱了我們自己寫的Observable，Subscriber訂閱的是filter方法返回的那個新的Observable對象，所以訂閱時候會調(diào)用OnSubscribeFilter的call方法，OnSubscribeFilter才是我們訂閱的被觀察者的onSubscribe對象，在OnSubscribeFilter的call()方法中，我們讓我們包裝的FilterSubscriber訂閱我們原來的被觀察者，也就是我們在外界生成的那個Observable。我們在外界的Observable的onSubscribe對象的call方法中得到的觀察者是FilterSubscriber對象，我們調(diào)用的onNext會回調(diào)到FilterSubscriber的onNext方法中。在FilterSubscriber的onNext方法中我們根據(jù)我們傳遞的Func1來判斷是否要回調(diào)真正的Subscriber的onNext方法，在為true的時候我們才回調(diào)我們外界的觀察者的onNext方法，也就起到了過濾的作用。這就是Filter的整個的流程。

我們來測試下我們的小結(jié)論：

 
 
  
  Observable.create(new Observable.OnSubscribe() {
  
                 @Override
  
                 public void call(Subscriber subscriber) {
  
                     Log.e("call:subscriber", "" + subscriber.getClass().getCanonicalName());
  
                     subscriber.onNext(5);
  
                 }
  
             }).filter(new Func1() {
  
                 @Override
  
                 public Boolean call(Integer integer) {
  
                     return integer > 0;
  
                 }
  
             }).subscribe(new Action1() {
  
                 @Override
  
                 public void call(Integer integer) {
  
                     
  
                 }
  
             });

分享文章：RxJava中操作符到底做了什么？
本文來源：http://m.fisionsoft.com.cn/article/cciegeo.html

新聞中心

其他資訊