RxJava 源碼解讀分析 from

我們繼續，看看observable.from()是怎麼回事，from源碼如下圖。 再來看看OnSubscribeFromArray這個類，如下圖 我們發現，OnSubscribeFromArray就是一個OnSubscribe，要實現了call()接口，call()方法中，只是設置了一個新的FromArrayProducer，再來看看child.setProducer()方法，如下圖： 由於原始的

>>阅读原文<<