首页
学习
活动
专区
工具
TVP
发布
社区首页 >问答首页 >异步迭代器Task<IEnumerable<T>>

异步迭代器Task<IEnumerable<T>>
EN

Stack Overflow用户
提问于 2014-04-25 21:51:51
回答 2查看 43.8K关注 0票数 40

我正在尝试实现一个返回迭代器的异步函数。想法是这样的:

代码语言:javascript
复制
    private async Task<IEnumerable<char>> TestAsync(string testString)
    {
        foreach (char c in testString.ToCharArray())
        {
            // do other work
            yield return c;
        }
    }

但是,会出现一条错误消息,指出该函数不能是迭代器块,因为Task<IEnumerable<char>>不是迭代器接口类型。有解决方案吗?

EN

回答 2

Stack Overflow用户

发布于 2017-09-13 21:04:56

这种东西的A more "batteries-included" implementation,包括语言支持,现在从C# 8.0开始可用。

现在,当至少将C# 8.0 (或更高版本)与.NET标准2.1 (或更高版本)和/或.NET核心3.0 (或更高版本)一起使用时,原始问题中的代码可能如下所示:

代码语言:javascript
复制
private async IAsyncEnumerable<char> TestAsync(string testString)
{
    foreach (char c in testString.ToCharArray())
    {
        // do other work, which may include "await"
        yield return c;
    }
}
票数 18
EN

Stack Overflow用户

发布于 2015-10-21 06:34:37

为了详细说明前面的答案,您可以使用Reactive Extensions的Observable.Create<TResult>系列方法来做您想做的事情。

下面是一个例子:

代码语言:javascript
复制
var observable = Observable.Create<char>(async (observer, cancel) =>
{
    for (var i = 0; !cancel.IsCancellationRequested && i < 100; i++)
    {
        observer.OnNext(await GetCharAsync());
    }
});

下面是如何在LINQPad中使用它的示例:

代码语言:javascript
复制
// Create a disposable that keeps the query running.
// This is necessary, since the observable is 100% async.
var end = Util.KeepRunning();

observable.Subscribe(
    c => Console.WriteLine(c.ToString()),
    () => end.Dispose());
票数 15
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/23295119

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档