前言
IAsyncEnumerable<T>支持返回异步迭代的枚举器，但在.NET 6之前，即使在API中使用了IAsyncEnumerable<T>，它还是使用同步方式输出，首先将结果缓冲到内存中，然后再写入响应中：
[HttpGet]
public IAsyncEnumerable<WeatherForecast> Get()
{var rng = new Random();async IAsyncEnumerable<WeatherForecast> streamWeatherForecastsAsync(){for (int index = 1; index <= 5; index++){WeatherForecast weatherForecast = new WeatherForecast{Date = $"{DateTime.Now:ss.fff}",TemperatureC = rng.Next(-20, 55),Summary = Summaries[rng.Next(Summaries.Length)]};await Task.Delay(1000);yield return weatherForecast;};};return streamWeatherForecastsAsync();
}
现在，在.NET 6中，我们可以使用异步流。
Demo
1.服务端
采用上面相同的代码，可以看到不同的返回效果：
IAsyncEnumerable实例采用异步方式迭代写入响应中，不再阻塞请求调用。
需要注意的是，只有使用System.Text.Json进行序列化时，此功能才会起作用。
2.客户端
同样，我们可以在客户端异步接收响应，示例代码如下：
HttpClient httpClient = new();var response = await httpClient.GetAsync("https://localhost:7211/WeatherForecast",HttpCompletionOption.ResponseHeadersRead
);var weatherForecasts = await response.Content.ReadFromJsonAsync<IAsyncEnumerable<WeatherForecast>>();await foreach (var weatherForecast in weatherForecasts)
{Console.WriteLine($"[{DateTime.Now:ss.fff}] {weatherForecast.Date}");
}但是，实际运行效果却是按照同步方式执行的：
这是因为，我们必须使用System.Text.Json提供的专门方法处理异步流反序列化：
var responseStream = await response.Content.ReadAsStreamAsync();
var weatherForecasts = JsonSerializer.DeserializeAsyncEnumerable<WeatherForecast>(responseStream,new JsonSerializerOptions{PropertyNameCaseInsensitive = true,DefaultBufferSize = 50});
需要将DefaultBufferSize设置较小的值，保证异步迭代及时返回。
结论
EF Core支持IAsyncEnumerable查询数据：
可以将EF Core从数据库中获取的数据直接使用异步流的方式传输到响应，无需大量内存缓冲数据，提高程序性能。
如果你觉得这篇文章对你有所启发，请关注我的个人公众号”My IO“
