-
— 在資料序列的開頭增加一項資料startWith( )
-
— 将多個Observable合并為一個merge( )
-
— 合并多個Observables,讓沒有錯誤的Observable都完成後再發射錯誤通知mergeDelayError( )
-
— 使用一個函數組合多個Observable發射的資料集合,然後再發射這個結果zip( )
-
,and( )
, andthen( )
— (when( )
) 通過模式和計劃組合多個Observables發射的資料集合rxjava-joins
-
— 當兩個Observables中的任何一個發射了一個資料時,通過一個指定的函數組合每個Observable發射的最新資料(一共兩個資料),然後發射這個函數的結果combineLatest( )
-
andjoin( )
— 無論何時,如果一個Observable發射了一個資料項,隻要在另一個Observable發射的資料項定義的時間視窗内,就将兩個Observable發射的資料合并發射groupJoin( )
-
— 将一個發射Observables的Observable轉換成另一個Observable,後者發射這些Observables最近發射的資料switchOnNext( )
() — 表示這個操作符目前是可選的
rxjava-joins
包的一部分,還沒有包含在标準的RxJava操作符集合裡
rxjava-joins