1. 程式人生 > >RXjava2 建立型操作符

RXjava2 建立型操作符

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型別

 

​​​​​​​