如何在Swift中使用Combine按顺序发起两个请求？

你的需求是让login()和updateImage()按顺序执行（先登录完成，再执行头像更新），同时处理每个任务的响应和错误，以下是具体解决方案：

核心方案：用flatMap实现顺序执行 #

flatMap正是Combine中用于链式执行异步任务的操作符——它会等待上游Publisher（login()）完成并输出值后，才会订阅下游的Publisher（updateImage()），完全满足你要的顺序执行需求。你当前的思路是对的，只是需要处理updateImage()的失败类型匹配问题。

调整后的完整代码 #

import Combine

// 假设的类型定义
struct Token: Codable { /* ... */ }
struct Status: Codable { /* ... */ }

func login() -> Future<Token, Error> { 
    // 你的登录逻辑
}
func updateImage() -> Future<Status, Never> { 
    // 你的头像更新逻辑
}

// 存储订阅的容器
var cancellables = Set<AnyCancellable>()

login()
    .flatMap { token -> AnyPublisher<Status, Error> in
        // 处理login的响应：保存token到本地
        saveTokenToLocal(token)
        
        // 关键：将updateImage的Never失败类型转换为Error，匹配上游类型
        return updateImage()
            .setFailureType(to: Error.self)
            .eraseToAnyPublisher()
    }
    .sink(
        receiveCompletion: { completion in
            switch completion {
            case .finished:
                // 两个任务都成功完成时触发
                print("登录与头像更新全部完成")
            case .failure(let error):
                // 此处捕获的是login()抛出的错误
                print("登录失败：\(error.localizedDescription)")
            }
        },
        receiveValue: { status in
            // 处理updateImage()的响应结果
            print("头像更新状态：\(status)")
        }
    )
    .store(in: &cancellables)

// 示例：保存token到本地的函数
func saveTokenToLocal(_ token: Token) {
    // 你的本地存储逻辑，比如UserDefaults或Keychain
}

关键细节解释 #

1. 为什么不用map/tryMap？

   • map仅用于同步转换上游输出的值，无法发起新的异步任务；
   • tryMap支持同步抛出错误，但同样不能订阅新的异步Publisher，因此两者都不适合链式执行异步操作。

2. 失败类型匹配处理
   你的updateImage()返回Future<Status, Never>（表示不会失败），但flatMap要求下游Publisher的失败类型必须和上游（login()的Error）一致。通过setFailureType(to: Error.self)可以把Never类型的失败转换成Error，解决类型不兼容的问题。

3. 错误与响应的处理

   • login()的错误会在sink的receiveCompletion的.failure分支捕获；
   • updateImage()不会失败，所以receiveValue分支必然会拿到它的响应结果；
   • 如果后续updateImage()需要支持失败，只需将其返回类型改为Future<Status, Error>，就可以去掉setFailureType的转换，错误会自动传递到sink的receiveCompletion中。

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