SwiftUI中如何提取Combine订阅器的共享receiveCompletion代码块？

嘿，这个需求太常见了——避免在每个Combine订阅里重复写一模一样的receiveCompletion逻辑，我们可以用几种简单的方式把这段代码抽出来复用：

方法1：定义可复用的闭包常量 #

最直接的方式就是把重复的处理逻辑封装成一个闭包，放在全局或者你项目里合适的地方（比如工具类、ViewModel基类里），然后在需要的订阅器里直接引用：

// 定义可复用的Completion处理闭包
let defaultCompletionHandler: (Subscribers.Completion<Error>) -> Void = { completion in
    switch completion {
    case .failure(let error):
        // 这里替换成你的实际错误处理逻辑，比如弹窗提示、日志上报
        print("请求失败：\(error.localizedDescription)")
    case .finished:
        // 完成时的通用逻辑，比如隐藏加载动画
        print("请求已完成")
    }
}

之后在订阅时直接传入这个闭包就行：

authenticate
    .receive(on: DispatchQueue.main)
    .sink(
        receiveCompletion: defaultCompletionHandler,
        receiveValue: { authResult in
            // 这里处理当前订阅独有的值逻辑
        }
    )
    .store(in: &cancellables) // 别忘了存储Cancellable，防止订阅被提前释放

方法2：给Completion扩展处理方法 #

如果想让代码更优雅，还可以给Subscribers.Completion写个扩展，把处理逻辑变成它的一个方法：

extension Subscribers.Completion where Failure == Error {
    func handleDefault() {
        switch self {
        case .failure(let error):
            print("请求失败：\(error.localizedDescription)")
        case .finished:
            print("请求已完成")
        }
    }
}

使用的时候就可以用更简洁的写法：

authenticate
    .receive(on: DispatchQueue.main)
    .sink(
        receiveCompletion: { $0.handleDefault() },
        receiveValue: { authResult in }
    )
    .store(in: &cancellables)

方法3：封装自定义Sink（进阶） #

如果你的重复逻辑不止Completion处理，连receive(on: DispatchQueue.main)这种线程切换也想一起复用，那可以给Publisher写个扩展，封装一个自定义的sink方法：

extension Publisher where Failure == Error {
    func sinkWithDefaultSetup(receiveValue: @escaping (Output) -> Void) -> AnyCancellable {
        return self
            .receive(on: DispatchQueue.main) // 把主线程切换也封装进来
            .sink(
                receiveCompletion: { completion in
                    switch completion {
                    case .failure(let error):
                        print("请求失败：\(error.localizedDescription)")
                    case .finished:
                        print("请求已完成")
                    }
                },
                receiveValue: receiveValue
            )
    }
}

这样订阅代码会变得超级简洁：

authenticate
    .sinkWithDefaultSetup { authResult in
        // 只需要处理当前订阅独有的值逻辑即可
    }
    .store(in: &cancellables)

选择建议 #

• 如果只是简单复用Completion逻辑，方法1最直接好上手；
• 追求代码可读性和优雅度，选方法2；
• 有更多重复逻辑（比如线程切换、通用值处理）要封装，用方法3更高效。

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