C#并发编程经典实例（第2版）

42

｜

第

3

章

3.6

　消耗异步流

问题

假设需要处理异步流的结果，这个过程也叫作

异步枚举

。

解决方案

消耗异步操作可以通过

await

来实现，消耗枚举通常通过

foreach

来实现，消耗异步枚举

则要将这两者结合起来，也就是使用

await foreach

来实现。假设现在有一个异步枚举，

它会对

API

响应分页，我们可以消耗它并把每个元素写入控制台：

IAsyncEnumerable<

string

> GetValuesAsync(HttpClient client);

public async

Task ProcessValueAsync(HttpClient client)

{

await foreach

(

string value in

GetValuesAsync(client))

{

Console.WriteLine(

value

);

}

}

从概念上看，

GetValuesAsync

被调用后返回了

IAsyncEnumerable<T>

。然后，

foreach

从该

异步枚举创建了异步枚举器。在异步枚举器中，“获取下一个元素”这一操作可能是异步

的，除此之外，它在逻辑上与常规枚举器相似。因此，

await foreach

会等待下一个元素

的到来，或者等待异步枚举器完成。如有元素传来，

await foreach

会执行其循环代码体，

如果异步枚举器已经完成，则会退出循环。

对每个元素都执行异步处理也是常规做法：

IAsyncEnumerable<

string

> GetValuesAsync(HttpClient ...