SwiftUI/Combine：订阅数组整体更新与数组元素更新的正确实现方案

前置误区澄清 #

你提到的_items.projectedValue并非非规范内部实现，它是@Published属性包装器公开投影值的底层存储，日常开发直接使用语法糖self.$items即可，这是苹果官方推荐的标准写法，完全符合开发规范。

1. 订阅数组整体的变更通知 #

你首次写法失效的原因是：items.publisher是序列自带的单次发布者，只会在初始化时把数组现有元素逐个发送后就结束生命周期，不会监听数组本身的后续变更。

正确实现直接订阅@Published的投影值即可，只要数组发生任意写操作（增删元素、修改元素属性、替换数组内容）都会触发回调，返回最新的完整数组：

struct Item: Identifiable, Equatable {
    var id = UUID()
    var title: String
}

class ItemStore: ObservableObject {
    @Published var items: [Item]
    private var cancellables = Set<AnyCancellable>()

    init(items: [Item] = []) {
        self.items = items
        // 标准数组整体变更订阅写法
        $items
            // 可按需加.dropFirst(n)跳过前n次回调，比如跳过初始赋值
            .sink(receiveValue: { fullArray in
                print("数组最新内容：\(fullArray)")
            })
            .store(in: &cancellables)
    }
}

2. 订阅数组内部单个元素的变更通知 #

根据元素类型的不同，有两种适配方案：

方案A：元素为值类型（struct） #

因为结构体是值类型，修改属性等价于替换数组中的元素实例，所以可以基于数组整体发布者做二次筛选：

// 监听指定ID的元素变更
let targetId: UUID // 传入要监听的元素ID
$items
    .compactMap { $0.first(where: { $0.id == targetId }) }
    .removeDuplicates() // 过滤非目标元素变更导致的无效触发，需要Item遵守Equatable
    .sink(receiveValue: { item in
        print("指定元素更新：\(item)")
    })
    .store(in: &cancellables)

该方案适合元素数量少、单元素监听需求不多的场景，优势是不需要改动原有结构体定义。

方案B：元素为引用类型（class） #

如果单元素变更频繁，推荐将元素改为遵守ObservableObject的类，修改元素属性时不会触发整个数组的变更通知，性能更好：

class Item: Identifiable, ObservableObject {
    let id = UUID()
    @Published var title: String // 要监听的属性用@Published修饰

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

class ItemStore: ObservableObject {
    @Published var items: [Item] = []
    private var cancellables = Set<AnyCancellable>()
    // 存储单个元素的订阅关系，避免重复订阅/内存泄漏
    private var itemCancellables = [UUID: AnyCancellable]()

    init(items: [Item] = []) {
        self.items = items
        // 监听数组变更，动态维护元素订阅
        $items
            .sink(receiveValue: { [weak self] newItems in
                guard let self = self else { return }
                // 清理已删除元素的订阅
                let validIds = newItems.map(\.id)
                self.itemCancellables.keys
                    .filter { !validIds.contains($0) }
                    .forEach { self.itemCancellables.removeValue(forKey: $0) }
                // 给新增元素添加订阅
                newItems.forEach { item in
                    guard self.itemCancellables[item.id] == nil else { return }
                    let cancellable = item.$title
                        .sink(receiveValue: { newTitle in
                            print("元素\(item.id)的title更新为：\(newTitle)")
                        })
                    self.itemCancellables[item.id] = cancellable
                }
            })
            .store(in: &cancellables)
    }
}

内容的提问来源于stack exchange，提问作者Dave Meehan