如何将 IEnumerable 方法转换为异步工作 [duplicate]-解网

问：

async Task<IEnumerable<T>> 抛出“is not an iterator interface type”错误（2 个答案）

异步迭代器 Task<IEnumerable<T>> （3 个答案）

16天前关闭。

我正在使用 c#、.net 6.0

我正在尝试将 IEnumerable 方法和 ot 的调用方方法转换为异步工作。

我有一个看起来像这样的代码：

    public IEnumerable<MyUser> getUsers()
    {
        return AccountById
            .Keys
            .SelectMany(accountId => {
                try
                {
                    return getUsersFor(accountId)
                        .Select(x => new MyUser(x,
                            SetAccountUniqueName(AccountById[accountId].Name,
                                AccountById[accountId].Id)));
                }
                catch (Exception ex)
                {
                    _log.Error(ex);
                    return Enumerable.Empty<MyUser>();
                }
            });
    }

    public IEnumerable<User> getUsersFor(string accountId)
    {
        ListUsersResponse usersResponse;
        string marker = null;
        do
        {
            using (var myClient = new ServiceClient(pass))
            {
                usersResponse =
                    myClient.ListUsersAsync(
                            new ListUsersRequest { Marker = marker, MaxItems = MAX_ITEMS })
                        .Result;
                foreach (var user in usersResponse.Users)
                {
                    yield return user;
                }
            }

            marker = usersResponse.Marker;
        } while (usersResponse.IsTruncated);
    }

如何将 getUsers（）和 getUsersFor（）转换为异步方法？

C# LINQ async-await yield

public async Task<IEnumerable<MyUser>> GetUsersAsync()
{
    var result = new List<MyUser>();

    foreach(var accountId in AccountById.Keys)
    {
        try
        {
            var user = await GetUsersForAsync(accountId);
            result.Add(new MyUser(user, SetAccountUniqueName(AccountById[accountId].Name,
                            AccountById[accountId].Id)));
        }
        catch (Exception ex)
        {
                _log.Error(ex);
                return Enumerable.Empty<MyUser>();
        }
    }
}

public async Task<IEnumerable<User>> GetUsersForAsync(string accountId)
{
    ListUsersResponse usersResponse;
    string marker = null;
    do
    {
        using (var myClient = new ServiceClient(pass))
        {
            usersResponse =
                await myClient.ListUsersAsync(
                        new ListUsersRequest { Marker = marker, MaxItems = MAX_ITEMS });

            foreach (var user in usersResponse.Users)
            {
                yield return user;
            }
        }

        marker = usersResponse.Marker;
    } while (usersResponse.IsTruncated);
}

如何将 IEnumerable 方法转换为异步工作 [duplicate]

How can I convert IEnumerable method to work asynchronously [duplicate]

评论

评论

评论