RXjava2 建立型操作符
阿新 • • 發佈:2018-12-06
create()
完整建立1個被觀察者物件(Observable
)
Observable.create(new ObservableOnSubscribe<Object>() {
@Override
public void subscribe(ObservableEmitter<Object> e) throws Exception {
}
});
just() / fromArray() / fromIterable()
區別:只是傳入的引數不一樣
快速建立1個被觀察者物件(Observable
傳送事件的特點:直接傳送 傳入的事件 最多隻能傳送10個引數
Empty() 僅傳送Complete事件,直接通知完成
error() 僅發生Error事件
Never() 不發生任何事件
defer() 延時建立:直到有觀察者被建立時,才動態建立被觀察者並且傳送事件
timer() 延遲指定時間後,傳送1個數值0 一般用於檢測
interval() 每隔指定時間 就傳送 事件
intervalRange()每隔指定時間 就傳送 事件,可指定傳送的資料的數量
從0開始、無限遞增1的的整數序列類似於interval()
,但可指定傳送的資料的數量
range() 類似於 intervalRange() ,只是傳送事件沒有延時而已
rangeLong() 類似於range() 區別在於一個支援Long型別 一個支援 Integer型別