create操作符是所有建立操作符的源頭,其他建立型的操作符都是通過create操作符來建立的
observable.create(new observable.onsubscribe()
// int i = 1 / 0;//模擬發生異常 會自動執行onerror(throwable e)方法
注意:訂閱是可以取消的,所有在執行call回掉事,應該增加isunsubscribed的判斷,以便在取消訂閱時不執行call中的相關**邏輯
RxJava 建立操作符 defer
defer的英文意思就是推遲,在這裡是推遲observable的建立,defer操作符是直到有訂閱者訂閱時,才通過observable的工廠方法建立observable,defer能保證observable的狀態是最新的 value 1 observable justobservable obser...
RxJava筆記 RxJava操作符
用來建立observable。public static observablecreate onsubscribef 把其他型別的物件和資料型別轉化成observable。observable.just 123 把其他型別的物件和資料型別轉化成observable。與just區別在與引數返回值不同 ...
RxJava操作符學習
操作符學習推薦閱讀 官方英文 翻譯中文 先來看乙個簡單的例子 被觀察者 observable.onsubscribeintegeronsubscribe new observable.onsubscribe 觀察者 subscriberintegersubscriber new subscriber...