Rx链式调用实现

通过不同的操作符,可以复杂的rx链式调用,比如

Observable.just(10)
.map { integer -> integer!!.toString() }
.subscribeOn(Schedulers.io())
.map { s -> "$s=>map" }
.observeOn(AndroidSchedulers.mainThread())
.map { s -> "$s=>map2" }
.subscribeOn(Schedulers.newThread())
.map { s -> "$s=>map3" }
.observeOn(Schedulers.computation())
.subscribe { s -> Log.i("RX", s) }

直观的可以看到,Observable可以不断通过点语法调用下一个操作符,整个代码非常扁平。

这和Builder模式使用非常像,但是他和buidler是有本质差异的。

可观测实例生成情况

先看第一个问题:

Observable的连续操作符是作用在同一个实例上吗?

既然我这么问了,从概率上来讲肯定要回答不是的。确实也不是,要验证这一点非常简单,

  1. 输出每一次操作符后的Observable对象,通过hash值判断;
  2. 通过分析内存中Observable的对象实例个数判断;
I/RX: rx.internal.util.ScalarSynchronousObservable@970b05
I/RX: rx.Observable@89675a
I/RX: rx.Observable@1e69f26
I/RX: rx.Observable@1138767
I/RX: rx.Observable@93c3914
I/RX: rx.Observable@18095bd
I/RX: rx.Observable@e8d87b2

从对象实例hash可以发现,所以打印的Observable对象地址都不同,这说明:

Observable链式调用过程中在不断创建新的Observable用于下一个操作符

更进一步分析对象实例个数,可以知道,几乎所有操作符都会产生新的Observable对象。比如前面的Demo,

  1. 一共产生了9个Observable可观测实例对象;
  2. 不同操作符产生的实例对象的实现类不一定相同,和源码实现有关;

Observable有什么

第二个问题

Observable到底是个啥?它里面有什么东西?

从命名上来说Observable是=>可观察的,在Rxjava中,基本等价于是开发API的唯一入口类,这个比较好理解,就像SDK一样,通过Observable一个类,我们可以触达几乎Rx的所有能力(hook机制除外,他不是业务调用的核心,只是一种配置)。

它里面的东西很多,主要是以下几种类型:

  1. 大量操作符函数,提供了系列操作符的静态方法
  2. 定义了OnSubscribe,Operator,Transformer
  3. subscribe订阅方法
  4. 唯一的成员变量OnSubscribe

在subscribe执行后会触发的OnSubscribe的call方法,类似于点击操作后,触发了OnClickLister的onClick方法吧

操作符实现

第三个问题

操作符是怎么实现的?

在上述Observable内存查看的时候,注意到一点,不同操作符生成的对象的内部引用onSubscribe是不同的,比如前面的9个实例中就有三种:

  • JustOnSubscribe
  • OnSubscribeMap
  • OperatorSubscribeOn
  • OnSubscribeLift

下面我们看下操作符的实现情况,以map为例。

在分析之前,先同步一下关键概念

类似的图出现在每一个Rx的操作符API说明文档,为例方便理解简单解释一下几个关键点:

  • Observable时间线:被观测对象的时间线,被观测对象(即Observable)可以根据自身情况不断发射事件出来,也可以发射单次事件就结束,比较常见的网络请求封装,即为一次发射。
  • Operator操作符:中间的箭头线和黑框,合在一起可以理解为对Observable做了一次操作符运算,单次操作运算可以理解为一次Transformation,比如flip,map,filter等。
  • 链式操作:每一次操作符之后,返回值是一个新的可观测对象Observable,可以开始新的一轮操作,或者结束操作,订阅结果
  • Observer观察者:最终通过subsribe操作,我们传入一个观察者,用于处理最后的返回值,观察者可以视为另一个广为人知的概念:监听器Listerner。

下面我们分析下map操作符,正如其名,map的作用就是对观测对象发射出的每一个事件,做一次"映射操作",单次返回值可以是新的数据类型,最后返回待map能力的Observable对象。

在源码实现层面,map的操作符有以下两步:

  1. 创建OnSubscribeMap对象,他是包装了map方法的OnSubscribe的具体实现类

  2. 调用Observable的构造函数,传入OnSubscribeMap的hook对象

关于hook相关的我们暂不分析,后续会用专门章节介绍他的实现,现在核心就是OnSubscribeMap的实现了。

总结一下调用关系:

  1. Observable的map实例化OnSubscribeMap对象
  2. OnSubscribeMap为OnSubscribe的一个实现类,subscribe后最终触发其call方法
  3. ObSubscribeMap的call中,实例化MapSubsriber对象,MapSubscriber是Subscriber的一个实现类,相当于一个中间层代理对象,在其onNext中执行map操作,并最终执行下一层的Subscriber

总结一下,整个map的精简流程:

每一个map操作符都会生成一个OnSubScibeMap对象,并在内部call的时候再生成代理对象MapSubsriber,实现对map的处理和下一层Subscriber的触发动作

整个实现情况也印证了一句话,任何软件问题都可以通过增加中间层来解决。

小结

现在总结一下链式调用的知识点:

  • 链式调用的过程中,每次操作符都会生成一个新的Observable并返回
  • 不同操作符有不同操作符的实现类,常见的有JustOnSubscribe,OnSubscribeMap,OperatorSubscribeOn,OnSubscribeLift
  • Observable有一个OnSubscribe的成员,在subscribe调用时,立刻执行OnSubscribe的call方法,这个OnSubscribe的不同实现类试分析操作符的核心所在
  • map操作符的实现就是通过引入OnSubScibeMap中间层和MapSubscriber代理对象,实现提前map操作。
powered by Gitbook最近更新 2019-10-10

results matching ""

    No results matching ""