在 ASP.NET Web API 中使用 IAsyncEnumerable<T> 作为 API 输出 触发问题的代码

如何解决在 ASP.NET Web API 中使用 IAsyncEnumerable<T> 作为 API 输出 触发问题的代码

新的 IAsyncEnumerable 接口很棒，但在通过 API 公开数据时会出现问题。

从端点 Anthony Chu's great post 获取代码...直到您获得超过 8162 条记录...IAsyncEnumerable 的缓冲区限制。

JsonSerialiser 尝试在通过网络发送之前缓冲整个集合，而我希望它作为流发送。

管道中有一个修复程序（可能适用于 .NET 6.0 - PR 创建于 2021-04-07，请参阅参考资料）。在问题线程（链接如下）中发布了一个解决方法，它应该可以工作......但是......

• 从 API 通过网络流式传输集合的当前最佳实践是什么（根据 Anthony Chu 的说法，将 IAsyncEnumerable 转换为 IEnumerable 显然很糟糕，因为它会阻止当前线程
• 社区中有没有人为此找到更好的解决方法？

触发问题的代码

[HttpGet]
public async IAsyncEnumerable<int> Get()
{
    for (int i = 0; i < 10000; i++)
    {
        yield return i;
    }
}

使用 .NET 5.0 会出现以下错误：

system.invalidOperationException: 'AsyncEnumerableReader' reached the configured maximum size of the buffer when enumerating a value of type 'IAsyncEnumerableSandBox.Controllers.TestController+<Get>d__2'. This limit is in place to prevent infinite streams of 'IAsyncEnumerable<>' from continuing indefinitely. If this is not a programming mistake,consider ways to reduce the collection size,or consider manually converting 'IAsyncEnumerableSandBox.Controllers.TestController+<Get>d__2' into a list rather than increasing the limit.

错误提示将 IAsyncEnumerable 转换为列表......但没有内置转换器。

参考文献

• 问题 1570：Developers using JsonSerializer can asynchronously (de)serialize IAsyncEnumerable<T>
• Direct link to workaround in the above issue
• 文章：Async Streams with IAsyncEnumerable in .NET Core 3
• 文章：Our failed attempt at IAsyncEnumerable

相关问题：Clarification on how IAsyncEnumerable works with ASP.NET Web API