结合操作（或者称合并操作）指的是将多个Observable序列进行组合，拼装成一个新的Observable序列。
1. startWith
该方法会在Observable序列开始之前插入一些事件元素。即发出事件消息之前，会先发出这些预先插入的事件消息。
image.png
let disposeBag = DisposeBag()
Observable.of(2, 3)
.startWith(1)
.subscribe(onNext: {print($0)})
.disposed(by: disposeBag)
结果如下：
1
2
3
2. concat
-
concat操作符将多个Observables按顺序串联起来，当前一个Observable元素发送完毕后，后一个 Observable 才可以开始发出元素。 -
concat将等待前一个 Observable 产生完成事件后，才对后一个Observable进行订阅。如果后一个是“热”Observable，在它前一个Observable产生完成事件前，所产生的元素将不会被发送出来。
image.png
et disposeBag = DisposeBag()
let subject1 = BehaviorSubject.init(value: "1")
let subject2 = BehaviorSubject.init(value: "A")
let variable = Variable.init(subject1)
variable.asObservable()
.concat()
.subscribe{ print($0) }
.disposed(by: disposeBag)
subject1.onNext("2")
subject1.onNext("3")
variable.value = subject2
subject2.onNext("I would be ignored")
subject2.onNext("B")
subject1.onCompleted()
subject2.onNext("C")
结果如下：
next(1)
next(2)
next(3)
next(B)
next(C)
3. merge
- 通过使用
merge操作符你可以将多个Observables合并成一个，当某一个Observable发出一个元素时，他就将这个元素发出。 - 如果，某一个
Observable发出一个onError事件，那么被合并的Observable也会将它发出，并且立即终止序列。
image.png
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)
结果如下：
20
40
60
1
80
100
1
4. zip
zip操作符将多个(最多不超过8个)Observables的元素通过一个函数组合起来，然后将这个组合的结果发出来。它会严格的按照序列的索引数进行组合。例如，返回的Observable的第一个元素，是由每一个源Observables的第一个元素组合出来的。它的第二个元素 ，是由每一个源Observables的第二个元素组合出来的。它的第三个元素 ，是由每一个源Observables的第三个元素组合出来的，以此类推。它的元素数量等于源Observables中元素数量最少的那个。
image.png
let disposeBag = DisposeBag()
let first = PublishSubject<String>()
let second = PublishSubject<String>()
Observable.zip(first, second) { $0 + $1 }
.subscribe(onNext: { print($0) })
.disposed(by: disposeBag)
first.onNext("1")
second.onNext("A")
first.onNext("2")
second.onNext("B")
second.onNext("C")
second.onNext("D")
first.onNext("3")
first.onNext("4")
结果如下：
1A
2B
3C
4D
5. combineLatest
combineLatest操作符将多个Observables中最新的元素通过一个函数组合起来，然后将这个组合的结果发出来。这些源Observables中任何一个发出一个元素，他都会发出一个元素（前提是，这些Observables曾经发出过元素）。
image.png
let disposeBag = DisposeBag()
let first = PublishSubject<String>()
let second = PublishSubject<String>()
Observable.combineLatest(first, second) { $0 + $1 }
.subscribe(onNext: { print($0) })
.disposed(by: disposeBag)
first.onNext("1")
second.onNext("A")
first.onNext("2")
second.onNext("B")
second.onNext("C")
second.onNext("D")
first.onNext("3")
first.onNext("4")
结果如下：
1A
2A
2B
2C
2D
3D
4D
6. withLatestFrom
withLatestFrom操作符将两个Observables中最新的元素通过一个函数组合起来，然后将这个组合的结果发出来。当第一个Observable发出一个元素时，就立即取出第二个Observable中最新的元素，通过一个组合函数将两个最新的元素合并后发送出去。
image.png
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")
结果如下：
1
1
2
