1

我正在构建一个 API,它将通过查询一个数据库来进行分页和排序,该数据库有很多条目,我停在我构建方法重载的地方,并且可以让它正常工作,至少以正确的方式我认为。

这是一个模拟代码:

    public virtual IAsyncEnumerable<PagedResults<T>> GetPagedItems(int i) 
    {
        return GetPagedItems(null, i);
    }

    public virtual async IAsyncEnumerable<PagedResults<T>> GetPagedItems(string s, int i) 
    {
        //here I get 2 datasets, one with the items (25 for instance)
        //and in the 2nd one I get the total count
        var datasets = await GetItemsFromDB<T>();

        var items = datasets[0].ToList();
        var totalCount = datasets[1].ReadFirst();

       yield return new PagedResults<T>
        {
            Items = items,
            TotalCount = totalCount
        };

    }

我的问题是,在第一种方法(唯一一个参数)中它可以工作,但没有'async'关键字。

在第一个实现中,我添加了异步,但我收到了来自 Visual Studio 的警告,说我无法从迭代器返回值(这是有道理的),然后添加了“yield async”,它抱怨我无法将 PagedResults 转换为IAsyncEnumerable<PagedResults>。

我想知道我的最终实现是否正确,如果我使用第一种方法,它是否可以进行异步流式传输。

4

0 回答 0