AsyncExtensions

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

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

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

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

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

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

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

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

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

• 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。