1.Observable对象的变换
之前的课时，讲解了RxJava的变换操作符，可以把事件或者队列转进行转变，变成新的事件或队列再发送出去。作为RxJava的一个核心功能，来看看源码是怎么实现的：
map()方法:
对Observable发射的每一项数据应用一个函数，执行变换操作：
publicfinalObservablemap(Func1 func){returnlift(newOperatorMap(func));}
下图展示了如何将一个乘法函数应用到每个发出的值上，以此创建一个新的Observable来发射转换的数据。
flatMap()方法:
有一个这样的Observable：它发射一个数据序列，这些数据本身也可以发射Observable。RxJava的flatMap()函数提供一种铺平序列的方式，然后合并这些Observables发射的数据，最后将合并后的结果作为最终的Observable。
publicfinalObservableflatMap(Func1> func){if(getClass() == ScalarSynchronousObservable.class) {return((ScalarSynchronousObservable)this).scalarFlatMap(func); }returnmerge(map(func));}
当我们在处理可能有大量的Observables时，重要是记住任何一个Observables发生错误的情况，flatMap()将会触发它自己的onError()函数并放弃整个链。
提示：关于合并部分，它允许交叉。正如上图所示，这意味着flatMap()不能够保证在最终生成的Observable中源Observables确切的发射顺序。
2.变换的原理：lift()和compose()
lift():
在变换操作符的内部，都调用了lift()方法，它是一个基础的变换方法。
//lift方法源码publicfinalObservablelift(finalOperator operator){returnnewObservable(newOnSubscribe() {@Overridepublicvoidcall(Subscriber o){ Subscriber st = hook.onLift(operator).call(o); st.onStart(); onSubscribe.call(st); } });}//Operator是Observable内部定义的接口，继承了Func1接口publicinterfaceOperatorextendsFunc1,Subscriber>{// cover for generics insanity}//Func1接口，传入一个泛型对象，返回一个R类型的对象publicinterfaceFunc1extendsFunction{Rcall(T t);}
官方解释：对一个Observale执行lift()方法，它会返回一个新的Observable；当订阅以后，新的Observable会通过相应的操作符把原Observable的数据传递出去。
流程：
（1）lift()先创建一个新的Observable，并传入一个新的OnSubscribe对象；
（2）当subscribe()订阅后，新Observable的新OnSubscribe会调用call()方法；
（3）OnSubscribe的call()中，hook的onLift()方法没有操作，相当于Operator调用了call()方法，传入原Subscriber，并创建一个新的Subscriber；
（4）新的Subscriber执行onStart()，进行订阅前的准备代码；原Observable的原onSubscribe调用call()方法，传入新的Subscriber；到这里就实现了Observable的类型转换，并且发送出去。
compose():
compose()方法应用一个特殊的变换方法对一个Observable对象进行转换。
//compose()方法publicObservablecompose(Transformer transformer){return((Transformer) transformer).call(this);}//Transformer接口，继承Func1接口，publicinterfaceTransformerextendsFunc1,Observable>{// cover for generics insanity}
同样是变换，那它和lift()有什么不同呢？
compose()方法是操作Observable本身，而lift()是操作Observable 的Subscribers 或者Observers
使用场景：
（1）如果所创建的操作符是旨在操作由原Observable发射的独立事件，选择lift()方法；
（2）如果你的操作符是为了旨在变换原Observable本身（比如用一些特殊的RxJava已有的操作符），选择compose()方法。
网友评论