-
— 過濾資料filter( )
-
— 隻發射最後的N項資料takeLast( )
-
— 隻發射最後的一項資料last( )
-
— 隻發射最後的一項資料,如果Observable為空就發射預設值lastOrDefault( )
-
— 将最後的N項資料當做單個資料發射takeLastBuffer( )
-
— 跳過開始的N項資料skip( )
-
— 跳過最後的N項資料skipLast( )
-
— 隻發射開始的N項資料take( )
-
andfirst( )
— 隻發射第一項資料,或者滿足某種條件的第一項資料takeFirst( )
-
— 隻發射第一項資料,如果Observable為空就發射預設值firstOrDefault( )
-
— 發射第N項資料elementAt( )
-
— 發射第N項資料,如果Observable資料少于N項就發射預設值elementAtOrDefault( )
-
orsample( )
— 定期發射Observable最近的資料throttleLast( )
-
— 定期發射Observable發射的第一項資料throttleFirst( )
-
throttleWithTimeout( )
— 隻有當Observable在指定的時間後還沒有發射資料時,才發射一個資料debounce( )
-
— 如果在一個指定的時間段後還沒發射資料,就發射一個異常timeout( )
-
— 過濾掉重複資料distinct( )
-
— 過濾掉連續重複的資料distinctUntilChanged( )
-
— 隻發射指定類型的資料ofType( )
-
— 丢棄所有的正常資料,隻發射錯誤或完成通知ignoreElements( )