-
3.常用操作符查看全部
-
2.常用操作符查看全部
-
1.常用操作符查看全部
-
from 攜帶一個數組查看全部
-
create just from查看全部
-
create transforming fidding handle error message查看全部
-
學習網站查看全部
-
RxJava 學習資料查看全部
-
subscribeOn()方法用于指定每個Observable(被觀察者)對象查看全部
-
AndroidSchedulers:是RxAndroid庫提供在安卓平臺的調度器(指定觀察者在主線程)查看全部
-
Schedulers(調度器):Rxjava堅決多線程問題的機制 種類: .io()//用于IO操作 .computation()//計算型 計算工作默認的調度器 .immediate()//立即執行 在當前線程執行代碼指定的工作 .newThread()//開啟一個新線程 開啟新線程執行任務 .trampoline()//按照順序來處理的 按順序處理隊列,并運行隊列中每一個任務查看全部
-
Catch:捕獲異常 onErrorRetrun:正常結束數據流,回調Oncompleted onErrorResumeNext:用正常的數據流代替數據項,自我替換,不可以捕獲到異常信息 OnExceptionResumeNext:用正常的數據流代替數據項,自我替換,并且可以捕獲到異常信息 Retry:重試去修復,保證數據的正常 Retrywhen:延遲一定時間后報錯,當數據發射完成后再發射給觀察者查看全部
-
組合型操作符 Zip:將兩個數據源根據時間間隔進行組合發射到觀察者,當其中一個Observable發送數據結束或者異常后,另一個數據源也會停止發射數據。 Merge:將兩個數據源組成一個新數據源發射到觀察者(根據時間點先后順序組合,無序的) StartWith:在當前數據源之前進行前置數據插入 CombineLattest:兩個數據源進行結合,時間內兩個數據源第一個數據可以組合第二個數據的時間內的所有數據,超過時間則第一個數據進行替換 Join:observableA.join(observableB, observableA產生結果生命周期控制函數, observableB產生結果生命周期控制函數, observableA產生的結果與observableB產生的結果的合并規則 SwithOnNext:兩組數據源,當時間重疊時,后一個數據源的重疊對象會覆蓋前一個數據源的重疊對象,然后組成一個新數據源發送給觀察者查看全部
-
Debounce:操作間隔一段時間未做操作,才會發射數據 Distinct::去重操作符,一個數據列表中去掉重復數據 ElementAt:獲取指定位置數據的操作符 Filter:自定義規則過濾數據 First:取列表數據的第一位數據 IgnoreElements:忽略列表的所有數據元素,不回調onnext,只走Onerror和onCompant Last:取數據列表的最后指定位數的數據 Sample:對數據進行取樣,取樣成功后再發射數據到觀察者,定時取樣 Skip:跳躍數據項指定數據 SkipLast::跳過數據列表的最后幾項 Take:取指定數據 TakeLast:取數據項列表的最后指定幾位數據查看全部
-
轉換操作符: MAP:一對一類型轉換 FlatMAP:一對多類型轉換 GroupBy:將同類型數據進行按不同類型分組 Buffer:將同類型數據按個數進行分組 Scan:數據進行相鄰累加 window:查看全部
舉報
0/150
提交
取消