Swift Combine，避免可选选项上的嵌套订阅者

Question

我有一个包含 User 对象的 AccountService 类。用户对象从网络请求中异步设置。 在我的 UI 中，我正在显示用户并希望使更改保持最新。我正在使用 Swift 组合框架来执行此操作。

问题：有没有办法避免对象上的嵌套订阅者？

我写了一些测试代码来说明这一点：

import UIKit
import Combine

class User: ObservableObject, CustomDebugStringConvertible {
    @Published
    var name: String

    init(name: String) {
        self.name = name
    }

    var debugDescription: String {
        return self.name
    }
}

class AccountService {

    @Published
    var user: User? = nil

    var userCancel: AnyCancellable?
    var userContentCancel: AnyCancellable?
    init() {
        self.userCancel = self.$user.sink { (user) in
            print("Set user: \(String(describing: user))")

            guard let user = user else { return }
            self.userContentCancel = user.$name.sink { _ in
                print("new name: \(String(describing: self.user))")
            }
        }
    }

    func setUseru(user: User) {
        self.user = user
    }

    func changeUserName(name: String) {
        self.user?.name = name
    }
}

let x = AccountService()
x.setUseru(user: User(name: "Philipp"))
x.changeUserName(name: "Tom")
x.setUseru(user: User(name: "Anna"))

在 Playgroud Xcode 版本 11.4.1、Swift 5 中运行

输出

Set user: nil
Set user: Optional(Philipp)
new name: nil
new name: Optional(Philipp)
Set user: Optional(Anna)
new name: Optional(Tom)

理想情况下，我只想在设置对象时收听self.$user.sinkAND，以了解对象内容何时更改。 我在设置用户名时玩过self.objectWillChange.send()，但我无法触发外部发布者。

我正在寻找摆脱的方法

guard let user = user else { return }
self.userContentCancel = user.$name.sink { _ in
    print("new name: \(String(describing: self.user))")
}

在我的实现中，只需从同一个 self.$user.sink { (user) in 实现中驱动所有内容。

Answer 1

是的，有办法。您可以简单地使用 Combine 的 flatMap 运算符：

将来自上游发布者的所有元素转换为新发布者，最多可指定您指定的最大发布者数量。

我的工作示例：

import Foundation
import Combine

class User: ObservableObject {
    @Published var name: String

    init(name: String) {
        self.name = name
    }

    var debugDescription: String {
        return self.name
    }
}

class AccountService {
    @Published var user: User? = nil
    var userCancel: AnyCancellable?
    
    init() {
        self.userCancel = self.$user
            .filter { $0 != nil }
            .flatMap { $0!.$name }
            .sink(receiveValue: { name in
                print(name)
            })
    }

    func setUseru(user: User) {
        self.user = user
    }

    func changeUserName(name: String) {
        self.user?.name = name
    }
}

let x = AccountService()
x.setUseru(user: User(name: "Philipp"))
x.changeUserName(name: "Tom")
x.setUseru(user: User(name: "Anna"))

程序的输出将是：

Philipp
Tom
Anna