如何拆分Combine发布者输出？ObservableObject多发布者处理问询

这是一个很典型的Combine数据流拆分场景，我来给你分享最优的实现方案，再一步步拆解逻辑：

完整代码示例 #

// 假设你的ViewModel实例是viewModel，订阅袋是bag
DatabaseRequest.Search(for: searchTerm)
    .publisher()
    .map { results in
        // 一次遍历完成专辑和艺术家的过滤，优化性能
        let (albums, artists) = results.reduce(into: ([SearchResult.Album](), [SearchResult.Artist]())) { accumulator, result in
            if let album = result as? SearchResult.Album {
                accumulator.0.append(album)
            } else if let artist = result as? SearchResult.Artist {
                accumulator.1.append(artist)
            }
        }
        // 取前3个任意类型的结果
        let top3 = Array(results.prefix(3))
        // 将三个结果打包成元组，方便后续一次性处理
        return (top3: top3, albums: albums, artists: artists)
    }
    .receive(on: DispatchQueue.main)
    .sink(receiveValue: { [weak self] output in
        guard let self = self else { return }
        // 一次性赋值给三个@Published变量
        self.viewModel.top3 = output.top3
        self.viewModel.albums = output.albums
        self.viewModel.artists = output.artists
    })
    .store(in: bag)

方案拆解与设计思路 #

1. 一次遍历过滤，兼顾性能与可读性
   我用reduce(into:)代替多次compactMap，只需要遍历原始结果数组一次就能同时筛选出专辑和艺术家数组，当结果数量较大时，这种方式的性能优势会更明显。如果你的结果量很小，也可以用更直观的简化写法：

   let albums = results.compactMap { $0 as? SearchResult.Album }
   let artists = results.compactMap { $0 as? SearchResult.Artist }
   

   两种写法都没问题，看你更看重性能还是代码简洁性。

2. 打包结果为元组，避免流拆分的复杂度
   因为三个@Published变量的数据源都是同一组原始结果，没必要把流拆分成三个独立的Publisher（比如用multicast或者share），直接在map里生成包含三个结果的元组，后续在sink里一次性解构赋值，是最简洁高效的方式。

3. 主线程更新UI绑定属性
   receive(on: DispatchQueue.main)确保后续的赋值操作在主线程执行——因为@Published属性通常用于绑定UI控件，必须在主线程更新才能正确触发UI刷新。

4. 弱引用避免内存泄漏
   在sink里用[weak self]捕获，再用guard let self = self解包，是Combine订阅中避免循环引用的标准做法，防止ViewModel因为被订阅闭包强引用而无法销毁。

额外说明 #

• 如果你的top3需要按特定规则排序后再取前3，只需要在取prefix(3)之前先添加排序逻辑：

  let top3 = Array(results.sorted(by: { /* 你的排序规则，比如按热度/名称排序 */ }).prefix(3))
  

• 如果原始Publisher是逐个发送SearchResult元素（而不是一次性发送数组），那需要先用collect()把元素收集成数组，再按上面的逻辑处理。

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