concatMap
将 Observable 的元素转换成其他的 Observable,然后将这些 Observables 串连起来

concatMap 操作符将源 Observable 的每一个元素应用一个转换方法,将他们转换成 Observables。然后让这些 Observables 按顺序的发出元素,当前一个 Observable 元素发送完毕后,后一个 Observable 才可以开始发出元素。等待前一个 Observable 产生完成事件后,才对后一个 Observable 进行订阅。
演示
1. let disposeBag = DisposeBag()
3. let subject1 = BehaviorSubject(value: "?")
4. let subject2 = BehaviorSubject(value: "?")
6. let variable = Variable(subject1)
8. variable.asObservable()
9. .concatMap { $0 }
10. .subscribe { print($0) }
11. .disposed(by: disposeBag)
13. subject1.onNext("?")
14. subject1.onNext("?")
16. variable.value = subject2
18. subject2.onNext("I would be ignored")
19. subject2.onNext("?")
21. subject1.onCompleted()
23. subject2.onNext("?")
输出结果:
1. next(?)
2. next(?)
3. next(?)
4. next(?)
5. next(?)
