AsyncSequence 回放器：为冷流注入热重播能力

设计一个可缓存历史值的 AsyncSequence，让新订阅者也能获取之前发出的元素。 · 难度：入门 · +10XP

AsyncSequence 回放器：为冷流注入热重播能力

标准的 AsyncStream 是冷流，新订阅者只能接收到后续元素。本教程实现一个 ReplayAsyncSequence，内部维护一个环形缓冲区，当新迭代器开始异步遍历时，会先重放缓冲区中的历史元素，再继续实时流。通过 Actor 隔离保证线程安全，并支持自定义缓冲区大小。

actor ReplayActor<Element> {
    private var buffer: [Element] = []
    private var continuations: [AsyncStream<Element>.Continuation] = []
    func append(_ element: Element) {
        buffer.append(element)
        for c in continuations { c.yield(element) }
    }
    func makeStream() -> AsyncStream<Element> {
        AsyncStream { cont in
            for item in buffer { cont.yield(item) }
            continuations.append(cont)
        }
    }
}