AsyncExtensions

AsyncExtensions 提供了一系列操作符，旨在简化 AsyncSequences 的创建和组合。

AsyncExtensions 可以被视为 Apple swift-async-algorithms 的伴侣库。目前，这两个库之间存在重叠，但当 swift-async-algorithms 变得稳定时，AsyncExtensions 中重叠的操作符将被弃用。尽管如此，AsyncExtensions 将继续提供社区需要但 Apple 未提供的操作符。

要在 SwiftPM 项目中使用 AsyncExtensions 库，请将以下行添加到 Package.swift 文件中的依赖项中

.package(url: "https://github.com/sideeffect-io/AsyncExtensions"),

将 "AsyncExtensions" 作为可执行目标的依赖项包含在内

.target(name: "<target>", dependencies: ["AsyncExtensions"]),

最后，将 import AsyncExtensions 添加到您的源代码中。

• AsyncBufferedChannel: 任务之间带缓冲的通信通道。元素不共享，并将分散在消费者之间（与 AsyncStream 相同）
• AsyncThrowingBufferedChannel: 任务之间抛出错误的带缓冲通信通道

• AsyncPassthroughSubject: 具有共享输出的主题
• AsyncThrowingPassthroughSubject: 抛出错误的具有共享输出的主题
• AsyncCurrentValueSubject: 具有共享输出的主题。维护并重放其当前值
• AsyncThrowingCurrentValueSubject: 抛出错误的具有共享输出的主题。维护并重放其当前值
• AsyncReplaySubject: 具有共享输出的主题。维护并重放缓冲数量的值
• AsyncThrowingReplaySubject: 抛出错误的具有共享输出的主题。维护并重放缓冲数量的值

• zip(_:_:): 将两个 AsyncSequence 压缩为一个元素元组的 AsyncSequence
• zip(_:_:_:): 将三个 AsyncSequence 压缩为一个元素元组的 AsyncSequence
• zip(_:): 将任意数量的异步序列压缩为一个元素数组
• merge(_:_:): 将两个 AsyncSequence 合并为一个元素 AsyncSequence
• merge(_:_:_:): 将三个 AsyncSequence 合并为一个元素 AsyncSequence
• merge(_:): 将任意 AsyncSequence 合并为一个元素 AsyncSequence
• withLatest(_:): 将来自自身的元素与来自另一个 AsyncSequence 的最新已知元素组合
• withLatest(_:_:): 将来自自身的元素与来自另外两个异步序列的最新已知元素组合

• AsyncEmptySequence: 创建一个立即完成的 AsyncSequence
• AsyncFailSequence: 创建一个立即失败的 AsyncSequence
• AsyncJustSequence: 创建一个发出一个元素并完成的 AsyncSequence
• AsyncThrowingJustSequence: 创建一个基于抛出错误的闭包发出元素并完成的 AsyncSequence
• AsyncLazySequence: 从基础序列的元素创建一个 AsyncSequence
• AsyncTimerSequence: 创建一个定期发出日期值的 AsyncSequence
• AsyncStream Pipe: 创建一个 AsyncStream 并返回一个元组，代表其输入和输出

• handleEvents(): 在自身的生命周期内执行闭包
• mapToResult(): 将来自自身的元素和错误映射到 Result 类型
• prepend(_:): 在自身前面添加一个元素
• scan(_:_:): 通过将当前元素以及闭包返回的最后一个值提供给闭包来转换来自自身的元素
• assign(_:): 将来自自身的元素赋值给属性
• collect(_:): 迭代来自自身的元素并执行闭包
• eraseToAnyAsyncSequence(): 擦除为 AnyAsyncSequence
• flatMapLatest(_:): 当自身是 AsyncSequence 的 AsyncSequence 时，将来自自身的元素转换为 AsyncSequence 并重新发布最近接收到的 AsyncSequence 发送的元素
• multicast(_:): 借助提供的 Subject 将来自自身的值共享给多个消费者
• share(): 将来自自身的值共享给多个消费者
• switchToLatest(): 当自身是 AsyncSequence 的 AsyncSequence 时，重新发布最近接收到的 AsyncSequence 发送的元素

更多操作符和扩展即将推出。当然欢迎提交 Pull Request。