1. Debounce/throtleWithTimeout

   • debounce(long,TimeUnit)或
     throttleWithTimeout(long,TimeUnit) :在一个数据发射后的一个时间段内，若没有新数据发射时，发射该数据；若有，则在新数据到来时重新计时，重复之前所叙逻辑。

     
     
   • debounce(long,TimeUnit,Scheduler)
     throttleWithTimeout(long,TimeUnit,Scheduler)
   • debounce(Func1)
     
     
     注意：源Observable触发onComplete()并不会使数据停止发射

2. distinct

   • distinct()
     distinct(Func1):去除重复数据
     
     
     注意：distinct会缓存之前发射的数据，当源Observable数据过大时，需要注意内存问题
   • distinctUntilChanged()
     distinctUntilChanged(Func1)：去除相邻重复的数据

3. elementAt

   • elementAt(int)：获取第n个数据，索引从0开始
     
     
     注意：若源Observaer发射的数量为n,索引i<0 或 i>n会导致IndexOutOfBoundsException.
   • elementAtOrDefault(int,T)：获取第n个数据，若不存在则发射默认值T

4. filter：发射满足条件的数据

   
   

5. first

   • first():发射第一个数据
     first(Func1)
     firstOrDefault(T)
     
     
     注意：first和firstOrDefault是阻塞式的，它会等待源Observable发射完成后才发射数据。
   • takeFirst(Func1): 和first类似
     注意：若源Observable未发射任何数据，first会抛出NoSuchElementException，takeFirst会返回一个空的Observable
   • single()：和first类似
     
     
     注意：如果源Observable发射的不是唯一的数据，则会抛出NoSuchElementException

   • single(Func1)

     
     

   • singleOrDefault(T)

     
     

   • singleOrDefault(Func1,T)

     
     

6. ignoreElements

   • ignoreElements()：忽略数据的发送，只会发送通知（onComplete(),onError()）

     
     

7. last

   • last()：发射最后一个数据，用法同first
     last(Func1)
     lastOrDefault(T)

8. sample/throttleLast

   • sample(long,TimeUnit) / throttleLast(long,TimeUnit)
     sample(long,TimeUnit,Scheduler) / throttleLast(long,TimeUnit,Scheduler)
     
     
     注意：最后的数据在指定的时间段内提前结束，则会丢失

   • sample(Observable)

     
     

   • throttleFirst(long,TimeUnit)
     throttleFirst(long,TimeUnit,Scheduler)

     
     

9. skip

   • skip(int):过滤开始的n个数据

     
     

   • skip(long,TimeUnit)
     skip(long,TimeUnit,Scheduler)

     
     

10. skipLast

    • skipLast(int)：过滤最后的n个数据

      
      

    • skipLast(long,TimeUnit)
      skipLast(long,TimeUnit,Scheduler)

      
      

11. take

    • take(int)/limit(int):发射前面n个数据
      
      
      注意：假设Oberserable在完成之前发射的数量为m，若m<n,不会抛异常或调用onError(),发射m个数据

    • take(long,TimeUnit)：发射指定时间段的数据
      take(long,TimeUnit,Scheduler)

      
      

12. takeLast

- takeLast(n):发射最后n个数据