README_CN.md

CombineAsync

CombineAsync 是基于 Combine Future 的封装。其对 Future 进行封装，提供 async 和 await api，以优雅的处理异步事件。

必备条件

• macOS 10.15+/iOS 13.0+/tvOS13.0+/watchOS6.0+
• Swift 5.0+

如果你的项目环境为 macOS 10.10+/iOS 9.0+/tvOS 9.0+/watchOS 2.0+，那么你有以下两种选择：

• CombineXAsync：基于 CombineX
• OpenCombineAsync：基于 OpenCombine

安装

Swift Package Manager (SPM)

Swift 包管理器是一个管理 Swift 代码分发的工具。它与 Swift 构建系统集成，以自动化下载、编译和链接依赖项的过程。

使用 Swift 包管理器构建 CombineAsync 需要 Xcode 11+ 以上版本

要使用 Swift 包管理器将 CombineAsync 集成到 Xcode 项目中，请将其添加到 Package.swift 中：

dependencies: [
    .package(url: "https://github.com/KKLater/CombineAsync.git", .upToNextMajor(from: "0.0.1"))
]

使用

异步操作需要包裹成 Combine 的 Future 对象

func background1() -> Future<Int, Error> {
    return Future<Int, Error> { promise in
        let i:Int = Int(arc4random() % 10)
        DispatchQueue.global().asyncAfter(deadline: DispatchTime.now() + DispatchTimeInterval.microseconds(i)) {
            promise(.success(1))
        }
    }
}

func background2(c: Int) -> Future<Int, Error> {
    return Future<Int, Error> { promise in
        let i:Int = Int(arc4random() % 10)
        DispatchQueue.global().asyncAfter(deadline: DispatchTime.now() + DispatchTimeInterval.microseconds(i)) {
            promise(.success(c + 10))
        }
    }
}

func background3(c: Int) -> Future<Int, Error> {
    return Future<Int, Error> { promise in
        let i:Int = Int(arc4random() % 10)
        DispatchQueue.global().asyncAfter(deadline: DispatchTime.now() + DispatchTimeInterval.microseconds(i)) {
            promise(.success(c + 100))
        }
    }
}

使用 async await api 之前：

self.background1().sink { (error) in
    print(error)
} receiveValue: { (a) in
    self.background2(c: a).sink { (error) in
        print(error)
    } receiveValue: { (b) in
        self.background3(c: b).sink { (error) in
            print(error)
        } receiveValue: { (c) in
            print(c) // 111
        }.store(in: &self.cancels)

    }.store(in: &self.cancels)
}.store(in: &cancels)

使用 async 和 await api 后：

async {
    do {
        let a = try await(self.background1())
        let b = try await(self.background2(c: a))
        let c = try await(self.background3(c: b))
        main {
            print(c) // 111
        }
    } catch {
        throw error
    }
}

License

CombineAsync 以 MIT 协议发布，查看 LICENSE 获取更多信息。