简书地址:
博客地址:
上一篇主要讲了
- RxSwift简介
- RxSwift简单体验(在控件中的简单使用)
- RxSwift常见操作(never, just, of, empty, creat等10个sequence的使用)
- RxSwift中Subjects
- 变换操作(map, flatMap等)和资源释放DisposeBag
- UIBindingObserver创建自己的监听者
本文主要内容
- 联合操作: 把多个Observable流合成单个Observable流
- elementAt, single, skip等过滤和约束操作
- toArray, reduce, concat等数学操作
一. 联合操作
- 联合操作就是把多个Observable流合成单个Observable流
1. startWith
- 在发出事件消息之前，先发出某个特定的事件消息。
- 比如发出事件2 ，3然后我startWith(1)，那么就会先发出1，然后2 ，3.
//未添加startWithObservable.of("2", "3").subscribe({ print($0) }).addDisposableTo(bag) /*输出顺序: next(2) next(3) completed *///使用startWithObservable.of("2", "3").startWith("1").subscribe({ print($0) }).addDisposableTo(bag) /*输出顺序: next(1) next(2) next(3) completed */复制代码 2. merge
- 合并两个Observable流合成单个Observable流，根据时间轴发出对应的事件
let subject1 = PublishSubject ()let subject2 = PublishSubject ()Observable.of(subject1, subject2) .subscribe({ print($0) }) .addDisposableTo(bag) print("-------------------------")Observable.of(subject1, subject2) .merge() .subscribe({ print($0) }) .addDisposableTo(bag) subject1.onNext("quan")subject1.onNext("jun")subject2.onNext("ya")subject2.onNext("jie")subject1.onNext("tian")subject2.onNext("guo") /*输出事件: next(quan) next(jun) next(ya) next(jie) next(tian) next(guo) */复制代码
3. zip
- 绑定超过最多不超过8个的Observable流，结合在一起处理。
- 注意Zip是一个事件对应另一个流一个事件
let subject3 = PublishSubject ()let subject4 = PublishSubject ()Observable.zip(subject3, subject4) { (sub3, sub4) -> String in sub3 + "+" + sub4 }.subscribe({ print($0) }) .addDisposableTo(bag) subject3.onNext("quan")subject3.onNext("jun")subject4.onNext("ya")subject4.onNext("jie")subject3.onNext("tian")subject4.onNext("guo") /*输出事件: 将subject3和subject4压缩到一起共同处理 next(quan+ya) next(jun+jie) next(tian+guo) */复制代码
4. combineLatest
- 绑定超过最多不超过8个的Observable流，结合在一起处理。
- 和Zip不同的是combineLatest是一个流的事件对应另一个流的最新的事件，两个事件都会是最新的事件，可将下图与Zip的图进行对比
let subject5 = PublishSubject ()let subject6 = PublishSubject ()Observable.combineLatest(subject5, subject6) { (sub5, sub6) -> String in sub5 + "+" + sub6 }.subscribe({ print($0) }).addDisposableTo(bag)subject5.onNext("quan")subject5.onNext("1")subject6.onNext("ya")subject6.onNext("2")subject5.onNext("--") /*输出事件: 将subject3的最新事件和subject4的最新事件一起处理 next(1+ya) next(1+2) next(--+2) */复制代码
5. switchLatest
- switchLatest可以对事件流进行转换，本来监听的subject1，我可以通过更改variable里面的value更换事件源。变成监听subject2了
let subject7 = BehaviorSubject(value: "love")//BehaviorSubject: 接受订阅之前的最后一个事件let subject8 = BehaviorSubject(value: "love to")let variable = Variable(subject7)variable.asObservable() .switchLatest() .subscribe({ print($0) }) .addDisposableTo(bag) subject7.onNext("ya")subject7.onNext("jie")variable.value = subject8subject7.onNext("quan")subject8.onNext("jun") variable.value = subject7subject8.onNext("jie")subject7.onNext("guo") /*输出事件: next(love) next(ya) next(jie) next(love to) next(jun) next(quan) next(guo) */复制代码 二. 过滤和约束
1. 1. distinctUntilChanged
- distinctUntilChanged就是当: 下一个事件与前一个事件是不同事件的事件才进行处理操作
Observable.of(1, 2, 1, 1, 1, 3, 3, 1) .distinctUntilChanged() .subscribe({ print($0) }) .addDisposableTo(bag) /*输出顺序为: next(1) next(2) next(1) next(3) next(1) completed */复制代码 2. elementAt
Observable.of(1, 2, 3, 4, 5) .elementAt(3) .subscribe({ print($0) }) .addDisposableTo(bag) /*输出顺序为: next(4) completed */复制代码 3. single
- 找出在sequence只发出一次的事件，如果超过一个就会发出error错误
>1 多个信号输出的情况
Observable.of(1, 2, 3, 4) .single() .subscribe({ print($0) }) .addDisposableTo(bag) /*输出顺序为: next(1) //单一信号超过了一个,只会输出第一个,然后输出error error(Sequence contains more than one element.) */复制代码 >2 指定某唯一信号的情况
Observable.of(1, 2, 3, 4) .single({ $0 == 2 }) .subscribe({ print($0) }) .addDisposableTo(bag) /*输出顺序为: next(2) completed */复制代码 >3 指定某不唯一信号的情况
Observable.of(1, 4, 3, 4) .single({ $0 == 4 }) .subscribe({ print($0) }) .addDisposableTo(bag) /*输出顺序为: next(4) //单一信号超过了一个,只会输出第一个,然后输出error error(Sequence contains more than one element.) */复制代码 >4 找不到该信号的情况
Observable.of(1, 4, 3, 4) .single({ $0 == 2 }) .subscribe({ print($0) }) .addDisposableTo(bag) /*输出顺序为: 没有对应的参数,然后输出error error(Sequence doesn't contain any elements.) */复制代码 4. filter
Observable.of(1, 2, 3, 4, 5) .filter({ $0 > 3 }) .subscribe({ print($0) }) .addDisposableTo(bag) /*输出顺序为: next(4) next(5) completed */复制代码 5. take
Observable.of(1, 2, 3, 4, 5) .take(2) .subscribe({ print($0) }) .addDisposableTo(bag) /*输出顺序为: next(1) next(2) completed */复制代码 6. takeLast
Observable.of(1, 2, 3, 4, 5) .takeLast(2) .subscribe({ print($0) }) .addDisposableTo(bag) /*输出顺序为: next(4) next(5) completed */复制代码 7. takeWhile
Observable.of(1, 2, 3, 4, 5) .takeWhile({ $0 > 3 }) .subscribe({ print($0) }) .addDisposableTo(bag) /*输出顺序为: next(4) next(5) completed */复制代码 8. takeUntil
- 接收事件消息，直到另一个sequence发出事件消息的时候.停止接收消息,输出completed
let subject1 = PublishSubject ()let subject2 = PublishSubject ()subject1.takeUntil(subject2) .subscribe({ print($0) }) .addDisposableTo(bag)subject1.onNext("quan")subject1.onNext("jun")subject2.onNext("ya")//停止接收消息 subject1.onNext("tian")subject2.onNext("guo") /*输出顺序为: next(quan) next(jun) completed */复制代码
9. skip
Observable.of(1, 2, 3, 4, 5) .skip(3) .subscribe({ print($0) }) .addDisposableTo(bag) /*输出顺序为: next(4) next(5) completed */复制代码 10. skipWhile
Observable.of(1, 2, 3, 4, 5) .skipWhile({ $0 < 4 }) .subscribe({ print($0) }) .addDisposableTo(bag) /*输出顺序为: next(4) next(5) completed */复制代码 11. skipWhileWithIndex
- 满足条件的都被取消，传入的闭包同skipWhile有点区别而已
skipWhile的(<4)和skipWhileWithIndex的(<=3)的效果是一样的
Observable.of(1, 2, 3, 4, 5) .skipWhileWithIndex({ (element, index) -> Bool in index <= 3 }) .subscribe({ print($0) }) .addDisposableTo(bag) /*输出顺序为: next(4) next(5) completed */复制代码 12. skipUntil
- 直到某个sequence发出了事件消息，才开始接收当前sequence发出的事件消息
let subject3 = PublishSubject ()let subject4 = PublishSubject ()subject3.skipUntil(subject4) .subscribe({ print($0) }) .addDisposableTo(bag)subject3.onNext("quan")subject4.onNext("jun") subject4.onNext("ya")//开始接收消息 subject3.onNext("tian")subject4.onNext("guo") /*输出顺序为: next(tian) */复制代码
三. 数学操作
1. toArray
- 将sequence转换成一个array，并转换成单一事件信号，然后结束
Observable.range(start: 1, count: 5) .toArray() .subscribe({ print($0) }) .addDisposableTo(bag) /*输出顺序为: next([1, 2, 3, 4, 5]) completed */复制代码 2. reduce
- 用一个初始值，对事件数据进行累计操作。reduce接受一个初始值，和一个操作符号
Observable.of(10, 12, 34) .reduce(0, accumulator: +) .subscribe({ print($0) }) .addDisposableTo(bag) /*输出顺序为: next(56) completed */复制代码 3. concat
- concat会把多个sequence和并为一个sequence，并且当前面一个sequence发出了completed事件，才会开始下一个sequence的事件。
- 在第一sequence发出onCompleted完成之前，第二个sequence发出的事件都会被忽略
let subject1 = BehaviorSubject(value: "quan")let subject2 = BehaviorSubject(value: "jun")let variable = Variable(subject1)variable.asObservable() .concat() .subscribe({ print($0) }) .addDisposableTo(bag)subject1.onNext("ya")subject1.onNext("jie")subject2.onNext("jun") //subject2不被输出 variable.value = subject2 //subject1发出onCompleted()之前会继续输出subject1 subject1.onNext("guo")subject2.onNext("tian") subject1.onCompleted() //subject1结束,开始输出subject2,此时subject2的值接受最后一个("tian") subject2.onNext("love")subject1.onNext("to love") //subject1将不再被输出 /*输出顺序为: next(quan) next(ya) next(jie) next(guo) next(tian) next(love) */复制代码 四. RxSwift的优点
- Composable 可组合，在设计模式中有一种模式叫做组合模式，你可以方便的用不同的组合实现不同的类
- Reusable 代码可重用，原因很简单，对应RxSwift，就是一堆Obserable
- Declarative 响应式的，因为状态不可变，只有数据变化
- Understandable and concise 简洁，容易理解。
- Stable 稳定，因为RxSwift写出的代码，单元测试时分方便
- Less stateful “无”状态性，因为对于响应式编程，你的应用程序就是一堆数据流
- Without leaks 没有泄漏，因为资源管理非常简单