Swift - RxSwift的使用详解12（算数&聚合

十二、算数、以及聚合操作（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)

运行结果如下：

RxSwift使用详解系列
原文出自:www.hangge.com转载请保留原文链接