concat

让两个或多个 Observables 按顺序串连起来

concat - 图1

concat 操作符将多个 Observables 按顺序串联起来,当前一个 Observable 元素发送完毕后,后一个 Observable 才可以开始发出元素。

concat 将等待前一个 Observable 产生完成事件后,才对后一个 Observable 进行订阅。如果后一个是“热” Observable ,在它前一个 Observable 产生完成事件前,所产生的元素将不会被发送出来。

startWith 和它十分相似。但是startWith不是在后面添加元素,而是在前面插入元素。

merge 和它也是十分相似。merge并不是将多个 Observables 按顺序串联起来,而是将他们合并到一起,不需要 Observables 按先后顺序发出元素。


演示

1. let disposeBag = DisposeBag()

3. let subject1 = BehaviorSubject(value: "?")
4. let subject2 = BehaviorSubject(value: "?")

6. let variable = Variable(subject1)

8. variable.asObservable()
9. .concat()
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(?)