RxJava都在用,你真的掌握了吗?2021玩转响应式编程框架RxJava,从用

在课程中老师写代码时,虽然直接在subscribe的时候立刻写observer.onSubscribe非常合理,但是仔细品一品的话还是有还原原版的RxJava的操作的味道的,因为要保证onSubscribe的线程不是subscribeOn指定的线程。
在线程调度这里,从订阅流来分析的话,因为订阅过程是首先将Observable lambda先执行订阅,然后交给上一层的Observable来订阅。假设下游有一个subscribeOn,在mainThread执行;在上游有一个subscribeOn,此时的subscribe操作在newThread执行,这样就导致最后发射事件的订阅方法ObsevableOnSubscribe#subscribe在newThread执行。