Combine框架中在sink内调用并发任务的简化写法？

默认的Combine sink闭包不支持直接调用异步函数，导致每次都要手动嵌套Task包裹异步逻辑，代码冗余。可以通过以下两种方式实现更简洁的写法：

方案1：自定义支持异步闭包的sink扩展 #

直接给Publisher添加重载方法，内部自动处理Task创建和弱引用捕获，完全贴合你期望的写法：

import Combine

extension Publisher where Failure == Never {
    // 基础版：直接接受异步闭包
    func sink(receiveValue: @escaping (Output) async -> Void) -> AnyCancellable {
        sink { value in
            Task {
                await receiveValue(value)
            }
        }
    }
    
    // 优化版：自动处理weak self捕获，避免手动可选绑定
    func sink<T: AnyObject>(weak object: T, receiveValue: @escaping (T, Output) async -> Void) -> AnyCancellable {
        sink { [weak object] value in
            guard let object = object else { return }
            Task {
                await receiveValue(object, value)
            }
        }
    }
}

使用示例 #

修改你的subscribe方法，直接用简化写法：

func subscribe() {
    // 带weak self的安全写法
    cancellable = service.publisher()
        .sink(weak: self) { self, value in
            await self.doThings(value: value)
        }
    
    // 如果不需要弱引用，也可以用基础版
    // cancellable = service.publisher()
    //     .sink { value in
    //         await self.doThings(value: value)
    //     }
}

方案2：用flatMap转异步任务为Publisher #

如果不想扩展Publisher，也可以通过flatMap将异步任务包装成Future Publisher，再进行订阅：

func subscribe() {
    cancellable = service.publisher()
        .flatMap { [weak self] value -> Future<Void, Never> in
            Future { promise in
                guard let self = self else {
                    promise(.success(()))
                    return
                }
                Task {
                    await self.doThings(value: value)
                    promise(.success(()))
                }
            }
        }
        .sink(receiveValue: { _ in })
}

这种方式逻辑清晰，但写法不如自定义扩展简洁，适合临时场景使用。

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