如何将AsyncEnumerable与同步SelectMany结合使用？

我在使用每次返回一组项的IAsyncEnumerable<IReadOnlyList<...>>时，想通过SelectMany或SelectManyAsync把所有项展平成单个IAsyncEnumerable<...>。目前能用嵌套循环实现：

IAsyncEnumerable<IReadOnlyList<...>> source = ...;
await foreach (var list in source)
{
    foreach (var item in list)
    {
        // 对item执行操作
    }
}

但尝试用LINQ写法（查询语法或方法语法）时，编译器抛出CS0411错误：“无法从用法推断AsyncEnumerable.SelectMany的类型参数”。我想知道：

• 是否可以在等待AsyncEnumerable后使用同步LINQ扩展？
• 是否存在类似我自定义的、支持查询语法的扩展方法？

我自己写的扩展方法如下：

public static async IAsyncEnumerable<T> SelectMany<TCollection, T>(this IAsyncEnumerable<TCollection> self, Func<TCollection, IEnumerable<T>> selector)
    where TCollection : IEnumerable<T>
{
    await foreach (var collection in self)
    {
        foreach (var item in selector(collection))
        {
            yield return item;
        }
    }
}

1. 使用官方提供的扩展方法 #

你遇到的CS0411错误，通常是因为没有正确匹配System.Linq.Async包中的SelectMany重载。只要你引用了Microsoft.Bcl.AsyncInterfaces NuGet包，就可以直接使用官方的重载来展平同步集合：

// 方法语法
var flattened = source.SelectMany(list => list);

// 查询语法
var flattened = from list in source
                from item in list
                select item;

官方的SelectMany已经包含了接受同步IEnumerable<T> selector的重载，不需要自己实现。如果还是报错，检查是否正确引用了NuGet包，或者显式指定类型参数帮助编译器推断：

var flattened = source.SelectMany<MyListType, MyItemType>(list => list);

2. 自定义扩展方法的可行性 #

你自己实现的扩展方法是完全可行的，逻辑和官方版本一致。如果因为环境限制无法引用官方包，或者需要自定义额外逻辑，这个实现可以正常工作，而且支持LINQ查询语法。

关于“等待AsyncEnumerable后使用同步LINQ” #

不建议这么做——如果先把整个IAsyncEnumerable异步枚举完再转成同步集合（比如用ToListAsync()），会失去异步流式处理的优势，尤其是在处理大数据量或远程数据源时，会一次性加载所有数据到内存，影响性能和内存占用。

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