如何在Combine中通过循环链式串行执行n个请求

嗨，这个需求Combine完全能优雅解决！要实现串行依次执行每个用户请求（前一个完成再启动下一个），最后返回所有用户数据的数组，核心可以用reduce操作符来串联请求，同时累积结果。

实现方案 #

直接看完整的函数实现：

func fetchAllUsers(ids: [Int]) -> AnyPublisher<[User], Error> {
    // 初始publisher：以空数组作为累积起点，同时匹配fetchUser的失败类型
    return ids.reduce(Just([User]()).setFailureType(to: Error.self)) { accumulatedPublisher, userId in
        accumulatedPublisher.flatMap { usersCollectedSoFar in
            self.fetchUser(for: userId)
                .map { newUser in
                    // 将新获取的用户追加到已收集的数组中
                    usersCollectedSoFar + [newUser]
                }
        }
    }
    .eraseToAnyPublisher()
}

关键逻辑解释 #

• 用reduce串联请求：reduce会遍历你传入的所有用户ID，把每一步的Publisher串联起来。初始值是一个发出空数组的Just，但因为Just默认没有失败类型，所以用setFailureType(to: Error.self)让它和fetchUser的Publisher类型匹配，这样才能在后续的flatMap中结合。
• 串行执行的核心：每次flatMap都会等待前一个accumulatedPublisher完成（也就是前一个用户请求结束），才会调用fetchUser发起下一个请求，完美满足“上一个请求完成后再启动下一个”的要求。
• 结果累积：每完成一个请求，就把新用户加到已收集的数组里，最终整个Publisher会发出包含所有用户的完整数组。

额外容错扩展（可选） #

如果某个用户请求失败时，你希望跳过错误继续执行剩下的请求，可以在fetchUser调用后加上catch处理，比如：

self.fetchUser(for: userId)
    .catch { _ in Just(User.empty) } // 用一个空用户占位，或者返回Empty跳过
    .map { usersCollectedSoFar + [$0] }

不过这时候需要根据业务需求调整返回类型（比如允许数组中有占位用户，或者后续过滤掉无效条目）。

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