Swift - RxSwift的使用详解12（算数&聚合操作符：toArray、reduce、concat）
作者：hangge | 2018-01-31 08:10
十二、算数、以及聚合操作（Mathematical and Aggregate Operators）
1，toArray
（1）基本介绍
- 该操作符先把一个序列转成一个数组，并作为一个单一的事件发送，然后结束。
（2）使用样例
let disposeBag = DisposeBag()
Observable.of(1, 2, 3)
.toArray()
.subscribe(onNext: { print($0) })
.disposed(by: disposeBag)
运行结果如下：
2，reduce
（1）基本介绍
- reduce 接受一个初始值，和一个操作符号。
- reduce 将给定的初始值，与序列里的每个值进行累计运算。得到一个最终结果，并将其作为单个值发送出去。
（2）使用样例
let disposeBag = DisposeBag()
Observable.of(1, 2, 3, 4, 5)
.reduce(0, accumulator: +)
.subscribe(onNext: { print($0) })
.disposed(by: disposeBag)
运行结果如下：
3，concat
（1）基本介绍
- concat 会把多个 Observable 序列合并（串联）为一个 Observable 序列。
- 并且只有当前面一个 Observable 序列发出了 completed 事件，才会开始发送下一个 Observable 序列事件。
（2）使用样例
let disposeBag = DisposeBag()
let subject1 = BehaviorSubject(value: 1)
let subject2 = BehaviorSubject(value: 2)
let variable = Variable(subject1)
variable.asObservable()
.concat()
.subscribe(onNext: { print($0) })
.disposed(by: disposeBag)
subject2.onNext(2)
subject1.onNext(1)
subject1.onNext(1)
subject1.onCompleted()
variable.value = subject2
subject2.onNext(2)
运行结果如下：
全部评论（0）