Note
- For English reader, please check the article which is written by Yaroslav Heriatovych.
這是一篇個人紀錄,基於RxJava2內Observable的所有函式
本頁用於決定在何種情境下使用Observable操作建立對應的Observable
我想要新增一個資料源 | 使用自訂的邏輯 | 送出資料 | Observable.create | ||
並且可和Disposable互動 | Observable.wrap | ||||
使用類似for-loop的行爲 | Observable.generate | ||||
送出給定的資料 | Observable.just | ||||
送出錯誤資料 | Observable.error | ||||
不送出資料並直接結束 | Observable.empty | ||||
不做任何事或結束 | Observable.never | ||||
從一個陣列 | 依序送出下個數值 | Observable.fromArray | |||
從一個Callable | Observable.fromCallable | ||||
從一個Future | Observable.fromFuture | ||||
從一個Collection | Observable.fromIterator | ||||
從一個Publisher | Observable.fromPublisher | ||||
在一個範圍內的數值 | Observable.range Observable.rangeLong | ||||
並每隔一段時間 | 從0 | Observable.interval | |||
從n | Observable.intervalRange | ||||
並在一段時間後送出一個0 | Observable.timer | ||||
並對每一個observer建立不同的資料源 | Observable.defer | ||||
並根據自訂的邏輯建立資料和資料源 | Observable.using | ||||
從一特定的 | Collection | 資料開始 | Observable.startWith Observable.startWithArray | ||
物件 | |||||
資料源 | |||||
陣列 |