国产xxxx99真实实拍_久久不雅视频_高清韩国a级特黄毛片_嗯老师别我我受不了了小说

資訊專欄INFORMATION COLUMN

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

sunny5541 / 1738人閱讀

摘要:今年徹底火了一把,其中最牛逼之處就是操作符了,以前只知道怎么用,這幾天看了看源碼,大致的弄清楚了操作符的工作過(guò)程,今天分享給大家。如果有什么不對(duì)地方,請(qǐng)大家多多指教。今天我們已為例,看代碼一個(gè)很簡(jiǎn)單的小例子,用過(guò)濾操作符找出大于等于的數(shù)字。

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

????今天我們已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()+",");
            }
        });

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

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

????調(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)去看看。

    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的實(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()方法都干了些什么

    @Override
        public void call(final Subscriber child) {
            FilterSubscriber parent = new FilterSubscriber(child, predicate);
            child.add(parent);
            source.unsafeSubscribe(parent);
        }
    
    出現(xiàn)了一個(gè)FilterSubscriber,什么鬼玩意兒,我們看看他是什么鬼
static final class FilterSubscriber extends Subscriber {

        final Subscriber actual;

        final Func1 predicate;

        boolean done;

        public FilterSubscriber(Subscriber actual, Func1 predicate) {
            this.actual = actual;
            this.predicate = predicate;
            request(0);
        }

        @Override
        public void onNext(T t) {
            boolean result;

            try {
                result = predicate.call(t);
            } catch (Throwable ex) {
                Exceptions.throwIfFatal(ex);
                unsubscribe();
                onError(OnErrorThrowable.addValueAsLastCause(ex, t));
                return;
            }

            if (result) {
                actual.onNext(t);
            } else {
                request(1);
            }
        }

        @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);
        }
    }
}

????一個(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é)論:

     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) {
                    
                }
            });

不知道大家看明白沒(méi)有,非常愿意和大家一起討論,一起學(xué)習(xí),歡迎留言

文章版權(quán)歸作者所有,未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為,您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請(qǐng)注明本文地址:http://specialneedsforspecialkids.com/yun/66244.html

相關(guān)文章

  • 扔物線:給 Android 開(kāi)發(fā)者的 RxJava 詳解

    摘要:觀察者模式面向的需求是對(duì)象觀察者對(duì)對(duì)象被觀察者的某種變化高度敏感,需要在變化的一瞬間做出反應(yīng)。規(guī)定,當(dāng)不會(huì)再有新的發(fā)出時(shí),需要觸發(fā)方法作為標(biāo)志。在事件處理過(guò)程中出異常時(shí),會(huì)被觸發(fā),同時(shí)隊(duì)列自動(dòng)終止,不允許再有事件發(fā)出。 我從去年開(kāi)始使用 RxJava ,到現(xiàn)在一年多了。今年加入了 Flipboard 后,看到 Flipboard 的 Android 項(xiàng)目也在使用 RxJava ,并且使...

    tianren124 評(píng)論0 收藏0

發(fā)表評(píng)論

0條評(píng)論

最新活動(dòng)
閱讀需要支付1元查看
<