RxSwift学习记录之操作符

filter 

通过true or false 过滤内容

ignoringElements

过滤掉所有next,可以接受到completed and error

elementAt 

指定不过滤第几个(range为0...more),例如elementAt(2)就是当next为第三次发送时候通知订阅者

skip 

指定跳过从0到第几个next

skipwhile 

指定从0个开始检测是否满足过滤条件,从不满足过滤条件的数据开始之后所有数据(包括后面不满足判断条件的数据)都会发送给订阅者

例如 数据22344, skip while {$0 %2 = 0} print 344

skipUntil

这个操作符针对观察者使用

例如observerA、observerB

observerA.skipUntill(observerB)

A会等待B接收到订阅后才会接收订阅 例如 

observerA.onNext("A") observerA.onNext("B") observerB.onNext("1") observerA.onNext("C")

print     1 C

take

take操作符是和skip相反的操作符,skip是跳过从第一个开始n个数据,而take是获取从第一个开始n个数据

takeWhile

takeWhile操作符从第一条数据开始,满足条件就会发送订阅,如果不满足条件,从不满足条件开始后面的数据都不会收到订阅(即使后面的数据有满足条件的)

takeUntil

与skipUntil相反,takeUntil A一直接受订阅,一直到B发送订阅后,A就再也无法接受订阅

©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 注:只包含标准包中的操作符,用于个人学习及备忘参考博客:http://blog.csdn.net/maplejaw...
    小白要超神阅读 2,230评论 2 8
  • RxJava操作符 创建操作 Range Range操作符根据初始值n和数目m发射一系列大于等于n的m个值 Def...
    Carve_Time阅读 7,936评论 2 18
  • 记录RxJava操作符,方便查询(2.2.2版本) 英文文档地址:http://reactivex.io/docu...
    凌云飞鱼阅读 835评论 0 0
  • 创建操作 用于创建Observable的操作符Create通过调用观察者的方法从头创建一个ObservableEm...
    rkua阅读 1,863评论 0 1
  • RxSwift 使用详解系列 Rx Rx是ReactiveX的缩写,简单来说就是基于异步事件序列的响应式编程。Rx...
    内心强大的Jim阅读 870评论 0 0