如何连接异步枚举？

Question

我有一个使用这种 return 类型的方法：

public async Task<IEnumerable<T>> GetAll()

它进行了一些进一步的异步调用（未知数量），每个调用 return 一个可枚举 T 的任务，然后想要连接 return.

的结果

var data1 = src1.GetAll();
var data2 = src2.GetAll();
var data3 = src3.GetAll(); //and so on

现在很容易等待所有结果并连接结果以生成单个可枚举项，但我希望可枚举项在第一次调用 return 时立即可用，并可能等待调用者/枚举器如果在可用结果运行出来时仍有任何调用未决。

我是否必须为此手动滚动一个 concat，以解决当它包装在任务 <> 中时缺少枚举器支持的问题？或者在 TPL 或其他地方已经有一个图书馆调用可以帮助我。我确实看过 IX，但它仍处于实验版本，不想将其折叠起来。

附带说明一下，我正在尝试的是反模式吗？我能想到一个复杂的问题，异常处理——从调用者的角度来看，调用可以成功完成，他开始使用可枚举的，但它可能会在中途爆炸...

Answer 1

有一个名为 Async Enumerable 的现有项目可以准确地回答这个问题。

你可以很容易地使用它。

例如：

IAsyncEnumerable<string> GetAsyncAnswers()
{
    return AsyncEnum.Enumerate<string>(async consumer =>
    {
        foreach (var question in GetQuestions())
        {
            string theAnswer = await answeringService.GetAnswer(question);
            await consumer.YieldAsync(theAnswer);
        }
    });
}

这公开了一个 IAsyncEnumerable<string>，它产生一次 GetAnswer returns。您可以在您的案例中在内部公开 IAsyncEnumerable<T> 并在 GetAll.

内部进行调用

what i'm trying an anti-pattern? I can think of one complication, exception handling - from the caller's side, the call can complete successfully and he starts using the enumerable but it can blow up midway through that...

我不会这么说。这确实有潜在问题，例如在其中一个等待期间内部发生异常，但这也可能潜在发生在任何IEnumerable<T>中.异步序列是当今新兴异步 API 的现实所需要的东西。

如何连接异步枚举？

How to concat async enumerables?

c#

ienumerable

asynchronous

task-parallel-library

async-await