天天看點

Combining 結合操作

  • startWith( )

    — 在資料序列的開頭增加一項資料
  • merge( )

    — 将多個Observable合并為一個
  • mergeDelayError( )

    — 合并多個Observables,讓沒有錯誤的Observable都完成後再發射錯誤通知
  • zip( )

    — 使用一個函數組合多個Observable發射的資料集合,然後再發射這個結果
  • and( )

    ,

    then( )

    , and

    when( )

    — (

    rxjava-joins

    ) 通過模式和計劃組合多個Observables發射的資料集合
  • combineLatest( )

    — 當兩個Observables中的任何一個發射了一個資料時,通過一個指定的函數組合每個Observable發射的最新資料(一共兩個資料),然後發射這個函數的結果
  • join( )

    and

    groupJoin( )

    — 無論何時,如果一個Observable發射了一個資料項,隻要在另一個Observable發射的資料項定義的時間視窗内,就将兩個Observable發射的資料合并發射
  • switchOnNext( )

    — 将一個發射Observables的Observable轉換成另一個Observable,後者發射這些Observables最近發射的資料
(

rxjava-joins

) — 表示這個操作符目前是可選的

rxjava-joins

包的一部分,還沒有包含在标準的RxJava操作符集合裡

繼續閱讀