RxJava 源码解读分析 observeOn

Observable.observeOn()方法有点绕，我们一点一点看。 从上图中，我们可以看出，observeOn主要作的工作是： 1，通过指定的scheduler来切换线程，用来emit数据，这个数据就是onNext(data)方法的参数。 2，emit出来的数据，先异步的缓存到一个buffer，实际上是缓存到了一个Queue中，注意，每调用一下observeOn()方法，就会new一个que

>>阅读原文<<