十一、结合操作（Combining Observables）
结合操作（或者称合并操作）指的是将多个 Observable 序列进行组合，拼装成一个新的 Observable 序列。
1，startWith
（1）基本介绍
- 该方法会在
Observable序列开始之前插入一些事件元素。即发出事件消息之前，会先发出这些预先插入的事件消息。
（2）使用样例
let disposeBag = DisposeBag()
Observable.of("2", "3")
.startWith("1")
.subscribe(onNext: { print($0) })
.disposed(by: disposeBag)
运行结果如下：
（3）当然插入多个数据也是可以的
let disposeBag = DisposeBag()
Observable.of("2", "3")
.startWith("a")
.startWith("b")
.startWith("c")
.subscribe(onNext: { print($0) })
.disposed(by: disposeBag)
运行结果如下：
2，merge
（1）基本介绍
- 该方法可以将多个（两个或两个以上的）
Observable序列合并成一个Observable序列。
（2）使用样例
let disposeBag = DisposeBag()
let subject1 = PublishSubject<Int>()
let subject2 = PublishSubject<Int>()
Observable.of(subject1, subject2)
.merge()
.subscribe(onNext: { print($0) })
.disposed(by: disposeBag)
subject1.onNext(20)
subject1.onNext(40)
subject1.onNext(60)
subject2.onNext(1)
subject1.onNext(80)
subject1.onNext(100)
subject2.onNext(1)
运行结果如下：
3，zip
（1）基本介绍
- 该方法可以将多个（两个或两个以上的）
Observable序列压缩成一个Observable序列。 - 而且它会等到每个
Observable事件一一对应地凑齐之后再合并。
（2）使用样例
let disposeBag = DisposeBag()
let subject1 = PublishSubject<Int>()
let subject2 = PublishSubject<String>()
Observable.zip(subject1, subject2) {
"\($0)\($1)"
}
.subscribe(onNext: { print($0) })
.disposed(by: disposeBag)
subject1.onNext(1)
subject2.onNext("A")
subject1.onNext(2)
subject2.onNext("B")
subject2.onNext("C")
subject2.onNext("D")
subject1.onNext(3)
subject1.onNext(4)
subject1.onNext(5)
运行结果如下：
4，combineLatest
（1）基本介绍
- 该方法同样是将多个（两个或两个以上的）
Observable序列元素进行合并。 - 但与
zip不同的是，每当任意一个Observable有新的事件发出时，它会将每个Observable序列的最新的一个事件元素进行合并。
（2）使用样例
let disposeBag = DisposeBag()
let subject1 = PublishSubject<Int>()
let subject2 = PublishSubject<String>()
Observable.combineLatest(subject1, subject2) {
"\($0)\($1)"
}
.subscribe(onNext: { print($0) })
.disposed(by: disposeBag)
subject1.onNext(1)
subject2.onNext("A")
subject1.onNext(2)
subject2.onNext("B")
subject2.onNext("C")
subject2.onNext("D")
subject1.onNext(3)
subject1.onNext(4)
subject1.onNext(5)
运行结果如下：
5，withLatestFrom
（1）基本介绍
- 该方法将两个
Observable序列合并为一个。每当self队列发射一个元素时，便从第二个序列中取出最新的一个值。
（2）使用样例
let disposeBag = DisposeBag()
let subject1 = PublishSubject<String>()
let subject2 = PublishSubject<String>()
subject1.withLatestFrom(subject2)
.subscribe(onNext: { print($0) })
.disposed(by: disposeBag)
subject1.onNext("A")
subject2.onNext("1")
subject1.onNext("B")
subject1.onNext("C")
subject2.onNext("2")
subject1.onNext("D")
运行结果如下：
6，switchLatest
（1）基本介绍
-
switchLatest有点像其他语言的switch方法，可以对事件流进行转换。 - 比如本来监听的
subject1，我可以通过更改variable里面的value更换事件源。变成监听subject2。
（2）使用样例
let disposeBag = DisposeBag()
let subject1 = BehaviorSubject(value: "A")
let subject2 = BehaviorSubject(value: "1")
let variable = Variable(subject1)
variable.asObservable()
.switchLatest()
.subscribe(onNext: { print($0) })
.disposed(by: disposeBag)
subject1.onNext("B")
subject1.onNext("C")
//改变事件源
variable.value = subject2
subject1.onNext("D")
subject2.onNext("2")
//改变事件源
variable.value = subject1
subject2.onNext("3")
subject1.onNext("E")
运行结果如下：
