RxJava 建立操作符create

2021-07-10 01:11:06 字數 582 閱讀 9666

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...