Swift 6中如何将异步函数/方法转换为Publisher

我太懂你这种纠结了——想把Swift的async函数转成Combine的Publisher，结果在Swift 6里碰了编译错误对吧？先看看你写的代码为啥会踩坑，再给你几个实用的解决办法。

首先还原下你的问题场景：

我试着写了个最简化的Swift 6示例来复现这个我搞不定的问题：

func getValue() async -> Int { 0 }

func getValuePublisher() -> AnyPublisher<Int, Never> {
    Future { continuation in
        Task {
            let value = await getValue()
            continuation(.success(value))
        }
    }.eraseToAnyPublisher()
}

这段代码在Swift 6里会报编译错误，核心原因是Swift 6的严格并发安全检查不允许你这么写——Future的设计逻辑是：它的初始化闭包必须同步完成对continuation的调用，或者说不能把continuation的调用丢到一个脱离当前上下文的Task里执行。你现在的写法里，Task会在Future的闭包返回后才执行，这违反了Future的并发安全约定，所以编译器直接报错了。

接下来给你几个靠谱的解决办法，按推荐程度排序：

办法一：用Combine官方的Async Publisher（最推荐） #

从iOS 15、macOS 12开始，Combine专门提供了Publishers.Async来快速把async/await函数包装成Publisher，完美适配Swift 6的并发规则，代码还特别简洁：

func getValue() async -> Int { 0 }

func getValuePublisher() -> AnyPublisher<Int, Never> {
    Publishers.Async {
        await getValue()
    }
    .eraseToAnyPublisher()
}

这个写法完全不需要手动处理continuation，编译器也不会有任何并发安全警告，是官方推荐的适配方式。

办法二：用Deferred + Future 兼容旧系统 #

如果你需要兼容更低版本的系统，或者一定要用Future的话，可以用Deferred来包装，同时给Task加上合适的并发上下文标记，避免Swift 6的检查报错：

func getValue() async -> Int { 0 }

func getValuePublisher() -> AnyPublisher<Int, Never> {
    Deferred {
        Future { continuation in
            Task { [continuation] in
                // 这里可以根据你的需求指定Actor，比如@MainActor
                let value = await getValue()
                continuation(.success(value))
            }
        }
    }
    .eraseToAnyPublisher()
}

Deferred的作用是延迟Future的创建，直到有订阅者订阅的时候才执行，这样能保证Task的执行时机和订阅时机绑定，避免不必要的并发问题。

额外补充：用AsyncStream转Publisher #

还有一种方式是用AsyncStream把async函数的结果包装成序列，再转成Publisher，这种方式也能通过Swift 6的并发检查：

func getValue() async -> Int { 0 }

func getValuePublisher() -> AnyPublisher<Int, Never> {
    AsyncStream {
        yield await getValue()
    }
    .eraseToAnyPublisher()
}

这种写法适合你需要把async函数的结果当成一个异步序列处理的场景，当然这里因为只发一次值，效果和上面的办法是一样的。

备注：内容来源于stack exchange，提问作者Matic Oblak