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

Question

我正在使用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() 转换为异步方法？

Answer 1

除非我遗漏了什么，否则你只需要更改你的签名即可

 public IEnumerable<User> getUsersFor(string accountId)

到

 public async Task<IEnumerable<User>> getUsersFor(string accountId)

并在异步方法中删除对

.Result

的调用并等待它们：

usersResponse = await myClient
    .ListUsersAsync(new ListUsersRequest { Marker = marker, MaxItems = MAX_ITEMS });

Answer 2

您需要删除

.Result

并将方法更改为与

async

和

await

关键字异步。

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

public async 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);
}