如何用Combine按顺序执行异步Prompter任务（替代Async/Await）

要实现和原async/await循环完全一致的顺序执行逻辑，核心是利用Combine的操作符保证每个提示任务在前一个完成后再启动，具体步骤如下：

1. 为Prompter协议扩展Combine发布者方法 #

先把异步的promptIfNeeded()方法包装成Combine发布者，方便后续链式调用：

import Combine

extension Prompter {
    // 将async方法转换为返回Bool的Never错误类型发布者
    func asPublisher() -> AnyPublisher<Bool, Never> {
        Future { [weak self] promise in
            guard let self = self else {
                promise(.success(false))
                return
            }
            Task {
                let result = await self.promptIfNeeded()
                promise(.success(result))
            }
        }
        .eraseToAnyPublisher()
    }
}

2. 构建顺序执行的发布者链 #

利用Publishers.Sequence将prompters数组转为发布者，再通过flatMap限制并发数为1，确保顺序执行：

// 存储订阅对象，防止被提前释放
private var cancellables = Set<AnyCancellable>()

// 构建顺序执行的发布者流
Publishers.Sequence(sequence: prompters)
    // maxPublishers设为1，保证前一个任务完成后才处理下一个
    .flatMap(maxPublishers: .max(1)) { prompter in
        prompter.asPublisher()
    }
    // 接收每个任务的结果
    .sink(receiveValue: { result in
        print("The result is \(result)")
    })
    // 将订阅存入cancellables
    .store(in: &cancellables)

逻辑说明 #

• Future负责桥接async/await方法和Combine发布者，在后台Task中执行异步提示逻辑，完成后将结果传递给下游。
• Publishers.Sequence会逐个输出数组中的Prompter实例。
• flatMap(maxPublishers: .max(1))是实现顺序执行的关键：它限制同时只订阅一个内部发布者，必须等当前提示任务完成，才会处理下一个Prompter的发布者。
• 最终的sink闭包会在每个提示任务完成时接收结果，和原循环中的print逻辑完全一致。

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