RxSwift：嵌套可观察对象上的 FlatMap答案

【问题标题】：RxSwift: FlatMap on nested observablesRxSwift：嵌套可观察对象上的 FlatMap
【发布时间】：2021-10-28 02:56:19
【问题描述】：

我有这个编辑器视图模型，我在其他不同的视图模型中使用它。父视图模型有一个可选择的用户，一旦选择了一个用户，我将需要一个带有新用户的编辑器的新实例。

这是编辑器和父级的简化版本。

class EditorViewModel {
    let user: String
    let item = PublishSubject<String>()
    
    init(user: String) {
        self.user = user
    }
}


class ParentViewModel {
    var editor: Observable<EditorViewModel>!
    let user = BehaviorSubject<String?>(value: nil)
    
    init() {
        editor = user.compactMap { $0 }.map { EditorViewModel(user: $0) }
    }
}

一旦编辑器保存了一个项目，我希望通过flatMaping 编辑器到它的项目来获得保存的项目。像这样：

let parent = ParentViewModel()

parent.editor.flatMapLatest { $0.item }.debug("item").subscribe(onNext: { item in
    print("This doesn't print")
})

parent.editor.subscribe(onNext: { editor in
    print("This one prints")
    editor.item.onNext("something")
})

parent.user.onNext("1")

flatMap 行确实订阅了，但它从来没有得到一个项目。

这是在操场上运行上述代码的输出：

2021-10-28 13:47:41.528: item -> subscribed
This one prints

另外，如果您认为这种设置过于疯狂，我同意并愿意接受建议。

【问题讨论】：

标签： reactive-programming rx-swift

【解决方案1】：

默认情况下，Observables 是冷的。这意味着每个订阅都是独立工作的，在这种情况下，每个订阅都会获得不同的 EditorViewModel。（.map { EditorViewModel(user: $0) } Observable 将为每个订阅调用其闭包。）

在.map { EditorViewModel(user: $0) } Observable 之后添加.share() 或.share(replay: 1) 会使其变热，这意味着所有订阅都将共享相同的效果。

至于您的子问题。我不认为我会设置这样的系统，除非这段代码之外的东西强迫我这样做。相反，我会将 Observable 传递给 EditorViewModel 而不是原始用户。这样您就无需在每次用户更改时重新构建编辑器视图模型。

【讨论】：