merge

将多个 Observables 合并成一个

通过使用 merge 操作符你可以将多个 Observables 合并成一个，当某一个 Observable 发出一个元素时，他就将这个元素发出。

如果，某一个 Observable 发出一个 onError 事件，那么被合并的 Observable 也会将它发出，并且立即终止序列。

演示

1. let disposeBag = DisposeBag()

3. let subject1 = PublishSubject<String>()
4. let subject2 = PublishSubject<String>()

6. Observable.of(subject1, subject2)
7. .merge()
8. .subscribe(onNext: { print($0) })
9. .disposed(by: disposeBag)

11. subject1.onNext("?️")

13. subject1.onNext("?️")

15. subject2.onNext("①")

17. subject2.onNext("②")

19. subject1.onNext("?")

21. subject2.onNext("③")

输出结果：

1. ?️
2. ?️
3. ①
4. ②
5. ?
6. ③