Swift中Combine框架里reduce(into:_:)的等效替代操作符是什么？

在Combine框架中，reduce操作符可以实现和Swift标准库reduce(into:_:)几乎一致的聚合功能，唯一区别是Combine的reduce需要显式指定初始值，闭包参数顺序略有不同，但核心逻辑完全匹配你的需求。

结合你的URL解析场景的示例 #

假设你需要从发布URL的Publisher异步处理并聚合查询项，用Combine的reduce可以这样实现：

import Combine

enum GenericError : Error {
    case with(message: String)
}

class Constants {
    fileprivate static let scheme = "sampleScheme"
    fileprivate static let host = "com.sampleHost"
    fileprivate static let authPath = "/auth"
    static let authQuery = "key"
}

// 模拟发布URL的Publisher
let urlPublisher = Just(URL(string: "sampleScheme://com.sampleHost/auth?key=123&name=test")!)
    .setFailureType(to: GenericError.self)

urlPublisher
    .tryMap { url in
        guard url.scheme == Constants.scheme,
              url.host == Constants.host,
              url.path == Constants.authPath,
              let urlComponents = URLComponents(url: url, resolvingAgainstBaseURL: true),
              let queryItems = urlComponents.queryItems else {
            throw GenericError.with(message: "Invalid deep link.")
        }
        return queryItems
    }
    // 使用Combine的reduce替代reduce(into:_:)
    .reduce([String: String]()) { result, item in
        var mutableResult = result
        mutableResult[item.name] = item.value
        return mutableResult
    }
    .map { query in
        query.filter { ["key"].contains($0.key) } // 对应原代码的queryPathsFilterByKey
    }
    .tryMap { result in
        guard !result.isEmpty else {
            throw GenericError.with(message: "Error parsing query Items (deep linking)")
        }
        return result
    }
    .sink(receiveCompletion: { completion in
        if case .failure(let error) = completion {
            print("Error: \(error)")
        }
    }, receiveValue: { result in
        print("Parsed result: \(result)")
    })

关键说明 #

1. 初始值传递：Combine的reduce第一个参数就是聚合的初始值，对应reduce(into:_:)的into参数。
2. 可变状态处理：Combine的reduce闭包需要返回新的聚合值，因此需先复制当前结果到可变变量中修改，再返回——这和reduce(into:_:)直接修改传入容器的写法略有不同，但最终效果一致。
3. 流适配：如果是处理异步流中的多个元素（比如连续发布的多个URL），reduce会持续聚合所有上游元素；如果仅处理单个元素（如原同步函数的场景），可先通过tryMap解析出queryItems，再用reduce完成聚合。

另外，若需要逐步输出每一步的聚合结果（而非仅最终结果），可以用Combine的scan操作符，用法和reduce类似，但会在每次聚合后将当前结果发送到下游。

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