RxJava 源碼解讀分析 observeOn

Observable.observeOn()方法有點繞，我們一點一點看。 從上圖中，我們可以看出，observeOn主要作的工作是： 1，通過指定的scheduler來切換線程，用來emit數據，這個數據就是onNext(data)方法的參數。 2，emit出來的數據，先異步的緩存到一個buffer，實際上是緩存到了一個Queue中，注意，每調用一下observeOn()方法，就會new一個que

>>阅读原文<<