c# 异步流（IAsyncEnumerable）如何处理异常-C#.Net教程

异常不会自动传播到IAsyncEnumerable消费端，而是延迟至首次MoveNextAsync()调用时抛出；foreach await无法捕获生成器构造、DisposeAsync或yield break后的异常，需显式管理枚举器并包裹MoveNextAsync()调用。

异常不会自动传播到 IAsyncEnumerable 消费端

调用 IAsyncEnumerable 的方法（如 GetAsyncEnumerator()）本身几乎不抛异常；真正执行异步逻辑的代码（比如 yield return 中的 await）发生的异常，**默认不会在枚举开始时立即暴露**，而是被“捕获并延迟到首次 MoveNextAsync() 调用时才抛出”。这意味着：你无法在 foreach await 语句块外提前感知底层迭代器构造阶段的失败。

在 foreach await 中 try/catch 只能捕获当前迭代项的异常

foreach await 是语法糖，底层展开为显式 await enumerator.MoveNextAsync() 调用。因此：

• 如果异常发生在某次 yield return 的 await 表达式中（例如 await httpClient.GetAsync(url) 失败），该异常会在对应那次 MoveNextAsync() 返回 false 前抛出，此时 try/catch 可以捕获
• 但一旦 MoveNextAsync() 返回 false（表示流结束），后续再调用它会直接返回已完成的 Task，**不会重放或重抛之前可能发生的异常**
• 若异常发生在 yield break 后、或 DisposeAsync() 中，标准 foreach await 无法捕获

await foreach (var item in GetItemsAsync())
{
    try
    {
        Process(item);
    }
    catch (OperationCanceledException)
    {
        // 这里捕获的是 Process() 抛的，不是 GetItemsAsync() 内部的
        break;
    }
}
// GetItemsAsync() 内部的异常，只能在 MoveNextAsync() 调用时被抛出 —— 即在 foreach 循环体内

想提前或统一处理生成器内部异常？必须手动控制枚举器

要确保生成器初始化或任意阶段的异常都被捕获，不能依赖 foreach await 的隐式行为，而应显式获取并管理 IAsyncEnumerator：