-
— 對序列的每一項都應用一個函數來變換Observable發射的資料序列map( )
-
,flatMap( )
, andconcatMap( )
— 将Observable發射的資料集合變換為Observables集合,然後将這些Observable發射的資料平坦化的放進一個單獨的ObservableflatMapIterable( )
-
— 将Observable發射的資料集合變換為Observables集合,然後隻發射這些Observables最近發射的資料switchMap( )
-
— 對Observable發射的每一項資料應用一個函數,然後按順序依次發射每一個值scan( )
-
— 将Observable分拆為Observable集合,将原始Observable發射的資料按Key分組,每一個Observable發射一組不同的資料groupBy( )
-
— 它定期從Observable收集資料到一個集合,然後把這些資料集合打包發射,而不是一次發射一個buffer( )
-
— 定期将來自Observable的資料分拆成一些Observable視窗,然後發射這些視窗,而不是每次發射一項window( )
-
— 在發射之前強制将Observable發射的所有資料轉換為指定類型cast( )