您好,欢迎来到二三四教育网。
搜索
您的当前位置:首页RxJava学习笔记3(操作符-过滤)

RxJava学习笔记3(操作符-过滤)

来源:二三四教育网
  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个数据

注意:会延迟发射直到源Observable 发射完成
- takeLast(long,TimeUnit):发射指定时间段的数据
takeLast(long,TimeUnit,Scheduler)

- takeLastBuffer(int):和takeLast类似,只是会把数据作为一个list一起发射

- takeLastBuffer(long,TimeUnit)
takeLastBuffer(long,TimeUnit,Scheduler)
takeLastBuffer(int,long,TimeUnit)
takeLastBuffer(int,long,TimeUnit,Scheduler)

Copyright © 2019- how234.cn 版权所有 赣ICP备2023008801号-2

违法及侵权请联系:TEL:199 1889 7713 E-MAIL:2724546146@qq.com

本站由北京市万商天勤律师事务所王兴未律师提供法律服务