从异步方法返回IAsyncEnumerable

Question

采取下列方法：

public async IAsyncEnumerable<int> Foo()
{
   await SomeAsyncMethod();
   return Bar(); // Throws since you can not return values from iterators
}

public async IAsyncEnumerable<int> Bar()
{
   for(int i = 0; i < 10; i++)
   {
       await Task.Delay(100);
       yield return i;
   }
}

我想知道最好的实践是什么，去做什么，上面的代码试图。基本上从一个IAsyncEnumerable方法返回一个async。

对我自己来说，我可以想象出两种方式：

1. 迭代IAsyncEnumerable并立即返回结果。

await foreach(var item in Bar())
{
    yield return item;
}

1. 创建了一个可以临时存储IAsyncEnumerable的结构，这似乎是更好的解决方案，但仍然有点过火。

return new AsyncEnumerableHolder<int>(Bar());

public struct AsyncEnumerableHolder<T>
{
    public readonly IAsyncEnumerable<T> Enumerable;

    public AsyncEnumerableHolder(IAsyncEnumerable<T> enumerable)
    {
        Enumerable = enumerable;
    }
}

有什么更好的方法来实现这种行为吗？

Answer 1

结构化方法是行不通的。如果要异步返回IAsyncEnumerator<T>值，可以在return Bar();中使用Task<IAsyncEnumerator<T>>。然而，这将是不寻常的。更自然的做法是创建一个新的IAsyncEnumerator<T>，它在异步枚举开始时集成了await SomeAsyncMethod()。要做到这一点，您应该按照选项(1)的建议使用await和yield：

public async IAsyncEnumerable<int> Foo()
{
  await SomeAsyncMethod();
  await foreach (var item in Bar())
    yield return item;
}

另外，对于这种“将整个序列枚举到我的结果序列”概念，JavaScript有一个非常好的yield*语法，它既支持同步序列，也支持异步序列。C#对于同步序列或异步序列都没有这种语法。