Swift并发：如何在for try await循环中处理单个错误不终止序列

当使用for try await遍历AsyncThrowingSequence时，直接将整个循环包裹在顶层do/catch块里确实会导致序列在遇到第一个错误时就终止——这是因为AsyncThrowingSequence的迭代器在抛出错误后会停止生成后续元素。要实现单个错误不中断整个序列的遍历，有几种实用方案：

方案1：手动控制Async迭代器，逐次处理错误 #

放弃for try await的语法糖，直接操作序列的迭代器，在每次调用next()时单独做错误处理：

let throwingSequence: AsyncThrowingSequence = ... // 你的抛出型异步序列
var iterator = throwingSequence.makeAsyncIterator()

while true {
    do {
        guard let element = try await iterator.next() else {
            break // 序列迭代完成，退出循环
        }
        // 处理正常获取到的元素
        print("处理元素：\(element)")
    } catch {
        // 处理单个元素的错误，处理完成后继续迭代后续元素
        print("捕获错误：\(error)")
        continue
    }
}

这种方式完全掌控了每一步的错误处理逻辑，错误不会向上传播终止整个循环。

方案2：将序列转换为Result类型的异步序列 #

通过map将原序列的每个元素包装成Result<Element, Error>，这样遍历的时候无需try，直接处理成功/失败分支：

let throwingSequence: AsyncThrowingSequence = ...

// 转换为Result序列
let resultSequence = throwingSequence.map {
    do {
        return .success(try await $0)
    } catch {
        return .failure(error)
    }
}

// 遍历Result序列，无终止风险
for await result in resultSequence {
    switch result {
    case .success(let value):
        print("处理成功：\(value)")
    case .failure(let error):
        print("处理错误：\(error)")
    }
}

如果需要复用这个转换逻辑，可以给AsyncThrowingSequence写个扩展：

extension AsyncThrowingSequence {
    func toResultSequence() -> AsyncMapSequence<Self, Result<Element, Error>> {
        map { element in
            do {
                return .success(try await element)
            } catch {
                return .failure(error)
            }
        }
    }
}

// 调用简化：
for await result in throwingSequence.toResultSequence() {
    // 处理逻辑同上
}

方案3：用try?忽略错误（仅适用于无需处理错误的场景） #

如果只需要处理成功的元素，忽略所有错误，可以直接用try?包裹迭代器的next()调用：

let throwingSequence: AsyncThrowingSequence = ...
var iterator = throwingSequence.makeAsyncIterator()

while let element = try? await iterator.next() {
    print("处理成功元素：\(element)")
}

注意：这种方式会直接跳过所有抛出错误的元素，无法捕获和处理错误，仅适合不需要关心错误的场景。

内容的提问来源于stack exchange，提问作者CompC