ios - Concat 运算符 RxSwift

Question

我有这样的代码:

let first = Observable<Int>.create({ observer -> Disposable in
    observer.onNext(1)
    return Disposables.create()
})
let second = Observable.of(4, 5, 6)
let observableConcat = Observable.concat([first, second])
observableConcat.subscribe({ (event) in
    print(event)
})

我对 concat 运算符的了解是“它订阅集合的第一个序列，中继它的元素直到它完成，然后移动到下一个。这个过程重复直到集合中的所有可观察对象都被使用” . 所以我期望代码片段的结果是 1、4、5、6，但我得到的只是 1。 请告诉我我对 concat 运算符的误解。

非常感谢。

Answer 1

第一个 observable 永远不会结束。您可以停止它添加 take(1):

Observable.concat([first.take(1), second])