RxSwift 小记-Mathematical and Aggr

（*useful）标记：目前觉得有用的函数
//FIXME 标记：待补充

toArray: 将可观察序列转换为数组，将该数组作为新的单个元素可观察序列发出

example("toArray") {
    let disposeBag = DisposeBag()
    
    Observable.range(start: 1, count: 10)
        .toArray()
        .subscribe { print($0) }
        .disposed(by: disposeBag)
}

打印：
next([1, 2, 3, 4, 5, 6, 7, 8, 9, 10])
completed

reduce 累加器，将所有的累加，然后作为一个Observable sequence emit消息

example("reduce") {
    let disposeBag = DisposeBag()
    
    Observable.of(10, 100, 1000)
        .reduce(7, accumulator: +)
        .subscribe(onNext: { print($0) })
        .disposed(by: disposeBag)
}

打印：
--- reduce example ---
1117

concat：（*useful）

合并队列，按加入顺序排列，只有上一个sequences发出了onCompleted后，下一个sequences才能Emit

example("concat") {
    let disposeBag = DisposeBag()
    
    let subject1 = BehaviorSubject(value: "🍎")
    let subject2 = BehaviorSubject(value: "🐶")
    
    let variable = Variable(subject1)
    
    variable.asObservable()
        .concat()
        .subscribe { print($0) }
        .disposed(by: disposeBag)
    
    subject1.onNext("🍐")
    subject1.onNext("🍊")
    
    variable.value = subject2
    
    subject2.onNext("I would be ignored")
    subject2.onNext("🐱")
    
    subject1.onCompleted()
    
    subject2.onNext("🐭")
}

打印：
next(🍎)
next(🍐)
next(🍊)
next(🐱) //这个不该被输出的，但是这使用了BehaviorSubject(会发送最近的一次emit）
next(🐭)