RxJava源码解读

zhoutk 发布于2019-08-19 11:38 / 1933人阅读

摘要：我们从最简单的一段代码入手实际上方法就是返回了一个创建了一个观察者主要有方法对应的执行的逻辑是对应的是类构造参数的回调接口调用了入参是创建了一个先会调用的然后调用根据上图其实就是调用

Observable observable = Observable.just("hello world");
Consumer consumer2 = new Consumer(){
    @Override
    public void accept(String s) throws Exception {
       System.out.println("Test1" + s);
    }
};
observable.subscribe(consumer2);

我们从最简单的一段代码入手()

Observable.just

实际上just方法就是返回了一个ObservableJust

ObservableJust

Observable.subscribe

创建了一个LambdaObserver观察者

LambdaObserver

主要有onSubscribe,onNext,onError,onComplete方法对应的执行的逻辑是对应的是类构造参数的回调接口

调用了ObservableJust.subscribeActual入参是LambdaObserver

创建了一个ScalarDisposable

ScalarDisposable

先会调用LambdaObserver的onSubscribe然后调用ScalarDisposable.run根据上图其实就是调用LambdaObserver.onNext

云服务器 GPU云服务器源码解读 webrtc源码解读 webrtc fec源码解读 js v8源码解读

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/77597.html

RxJava系列六（从微观角度解读RxJava源码）

摘要：而这个就是线程调度的关键前面的例子中我们通过指定了发射处理事件以及通知观察者的一系列操作的执行线程，正是通过这个创建了我们前面提到的。总结这一章以执行流程操作符实现以及线程调度三个方面为切入点剖析了源码。转载请注明出处：https://zhuanlan.zhihu.com/p/22338235 RxJava系列1(简介) RxJava系列2(基本概念及使用介绍) RxJava系列3...

zero 2019-08-14 17:16 评论0 收藏0
RxJava系列二（基本概念及使用介绍）

摘要：作用默认的，直接在当前线程运行总是开启一个新线程用于密集型任务，如异步阻塞操作，这个调度器的线程池会根据需要增长对于普通的计算任务，请使用默认是一个，很像一个有线程缓存的新线程调度器计算所使用的。这个使用的固定的线程池，大小为核数。转载请注明出处：https://zhuanlan.zhihu.com/p/20687307 RxJava系列1(简介) RxJava系列2(基本概念及使...

Profeel 2019-08-14 17:14 评论0 收藏0