RxSwift 系列(五) -- Filtering and Conditional Operators

前言

本篇文章将要学习RxSwift中过滤和条件操作符,在RxSwift中包括了:

  • filter
  • distinctUntilChanged
  • elementAt
  • single
  • take
  • takeLast
  • takeWhile
  • takeUntil
  • skip
  • skipWhile
  • skipWhileWithIndex
  • skipUntil

filter

Observable序列中只发出满足过滤条件的事件。

let disposeBag = DisposeBag()
    
Observable.of(1,2,3,4,5).filter({$0 > 2}).subscribe(onNext: {print($0)}).disposed(by: disposeBag)

打印结果:

3
4
5

distinctUntilChanged

过滤连续发出的相同事件

let disposeBag = DisposeBag()
Observable.of(1,2,3,3,3,2,2,5,4).distinctUntilChanged().subscribe(onNext: {print($0)}).disposed(by: disposeBag)

打印结果:

1
2
3
2
5
4

elementAt

Observable只发出指定位置的事件

let disposeBag = DisposeBag()
    
Observable.of(1,2,3,5,4).elementAt(2).subscribe(onNext: {print($0)}).disposed(by: disposeBag)

打印结果:

3

single

用法一:检测Observable序列是否发射一个元素。如果发射多个,会报错。

let disposeBag = DisposeBag()

// error:Sequence contains more than one element
// Observable.of(1,2,3).single().subscribe(onNext: {print($0)}).disposed(by: disposeBag)

Observable.of(1).single().subscribe(onNext: {print($0)}).disposed(by: disposeBag)

用法二:检测Observable序列发射的元素里面是否包含多个指定的元素,如果有多个或者没有,会报错。

let disposeBag = DisposeBag()
Observable.of("?", "?", "?", "?", "?", "?")
    .single { $0 == "?" }
    .subscribe { print($0) }
    .disposed(by: disposeBag)
    
Observable.of("?", "?", "?", "?", "?", "?")
    .single { $0 == "?" }
    .subscribe { print($0) }
    .disposed(by: disposeBag)
    
Observable.of("?", "?", "?", "?","?")
    .single { $0 == "?" }
    .subscribe { print($0) }
    .disposed(by: disposeBag)

打印结果:

next(?)
completed
error(Sequence doesn't contain any elements.)
next(?)
error(Sequence contains more than one element.)

take

Observable序列开始点起只处理前几个事件。

let disposeBag = DisposeBag()
    
Observable.of(1,2,3).take(2).subscribe(onNext: {print($0)}).disposed(by: disposeBag)

打印结果:

1
2

takeLast

take相反,从Observable序列的结束位置起,只处理前几个事件。

let disposeBag = DisposeBag()    
Observable.of(1,2,3).takeLast(2).subscribe(onNext: {print($0)}).disposed(by: disposeBag)

打印结果:

2
3

takeWhile

只处理满足条件的事件。感觉和filter没什么区别

let disposeBag = DisposeBag()
Observable.of(1,2,3,4,5).takeWhile{$0 < 3}.subscribe(onNext: {print($0)}).disposed(by: disposeBag)

打印结果:

1
2

takeUntil

直到另一个Observable序列发出一个信号,则原序列终止。

let disposeBag = DisposeBag()
    
let orinSubject = PublishSubject<Int>()
let refreSubject = PublishSubject<Int>()
    
orinSubject.takeUntil(refreSubject).subscribe(onNext: {print($0)}).disposed(by: disposeBag)
    
orinSubject.onNext(1)
orinSubject.onNext(2)
refreSubject.onNext(10)
orinSubject.onNext(3)

打印结果:

1
2

skip

Observable序列的元素跳过指定个数。

let disposeBag = DisposeBag()
Observable.of(1,2,3,4,5,6).skip(2).subscribe(onNext: {print($0)}).disposed(by: disposeBag)

打印结果:

3
4
5
6

skipWhile

跳过满足条件的事件,只要遇见不满足条件的事件,则该事件以及之后的事件(不管是否满足条件)都会发出。

let disposeBag = DisposeBag()    
Observable.of(1,2,3,4,5,6).skipWhile{$0 < 3}.subscribe(onNext: {print($0)}).disposed(by: disposeBag)

打印结果:

3
4
5
6

skipWhileWithIndex

跳过索引满足条件的事件。

let disposeBag = DisposeBag()
Observable.of(1,2,3,4,5,6).skipWhileWithIndex({ (element, index) -> Bool in
        index < 3
    }).subscribe(onNext: {print($0)}).disposed(by: disposeBag)

打印结果:

4
5
6

skipUntil

跳过另一个Observable序列发出事件之前的所有事件。与takeUntil相反。

let disposeBag = DisposeBag()
    
let oriSubject = PublishSubject<Int>()
let refreSubject = PublishSubject<Int>()
    
oriSubject.skipUntil(refreSubject).subscribe(onNext: {print($0)}).disposed(by: disposeBag)
    
oriSubject.onNext(1)
oriSubject.onNext(2)
    
refreSubject.onNext(10)
oriSubject.onNext(3)
oriSubject.onNext(4)

打印结果:

3
4

致谢

如果发现有错误的地方,欢迎评论,感谢!

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏XAI

Java生成SM2证书基于BouncyCastle(cer)

Java生成SM2证书基于BouncyCastle(cer) 可以先加QQ 783021975 咨询相关问题。代码后续会更新一部分 整理中。完全是Java代码调...

2.3K5
来自专栏Python疯子

python hashlib模块

hashlib主要提供字符加密功能,将md5和sha模块整合到了一起,支持md5,sha1, sha224, sha256, sha384, sha512等算法

1232
来自专栏三流程序员的挣扎

RxJava 创建操作符

内部触发对 Observer 的 onNext 方法的调用,just 中传递的参数将直接在 onNext 方法中接收到,参数的类型要和 Observer 的泛型...

2461
来自专栏杨逸轩 ' sBlog

Java实现微信跳一跳抓包修改分数

4106
来自专栏菩提树下的杨过

RxJava2学习笔记(3)

接上回继续,今天来学习下zip(打包)操作 一、zip操作 @Test public void zipTest() { Obse...

4486
来自专栏ccylovehs

武电实业卡密接口对接经验分享

以往卡密都是电信直接提供txt文件我们这边再导入数据库中,现在电信要求厂家获取卡密必须通过接口调用,此次对接主要用到三个方面知识:

1191
来自专栏linjinhe的专栏

对称加密算法和分组密码的模式

由于加密出来的数据很可能有很多不可见字符,因此这里会将加密后的结果进行一次Base64Encode。

4376
来自专栏IT笔记

JAVA版微信小程序用户数据的签名验证和加解密

签名验证和加解密 数据签名校验 为了确保 开放接口 返回用户数据的安全性,微信会对明文数据进行签名。开发者可以根据业务需要对数据包进行签名校验,确保数据的完整性...

6645
来自专栏三流程序员的挣扎

RxJava 连接操作符

看注释意思是将所有数据按原来的顺序缓存起来,就是不知道观察者什么时候订阅,什么时候解除订阅,所以缓存起来,以后直接用。

2312
来自专栏三流程序员的挣扎

RxJava 错误处理操作符

在源 Observable 遇到错误时,立即停止源 Observable 的数据发送,并用新的 Observable 对象进行新的数据发送。

3392

扫码关注云+社区

领取腾讯云代金券