解决方法中的 IQueryable 和 Async

Question

我正在尝试结合异步原理并正确实施。 在下面的代码中，departmentRepository.GetAll 返回 IQueryable。之后，GetPage(1,3) 返回 IEnumerable。只是好奇根据 Intellisense，新代码行是否有意义。

原始代码：

应用服务代码：

public async Task<IEnumerable<DepartmentDto>> GetAllDepartments()
{
    var departments = await departmentRepository.GetAll();
    Paged<Department> departmentPaged = new Paged<Department>(departments);
    var departments2 = departmentPaged.GetPage(1, 3);
    var departmentDto = mapper.Map<IEnumerable<Department>, IEnumerable<DepartmentDto>>(departments2);
    return  departmentDto;
}

第一行 await departmentRepository.GetAll() 给了我一个错误。

IQueryable 不包含 GetAwaiter 的定义和不可访问的扩展方法 Getawaiter`

所以 Intellisense 建议更改为

var departments = await departmentRepository.GetAll().ToListAsync();

更改后，在 var department2 = departmentPaged.GetPage(1, 3); 行弹出第二个错误

无法将 System.Collections.Generic.List 转换为 System.Linq.IQueryable。

所以 Intellisense 建议改成

Paged<Department> departmentPaged = new Paged<Department>(departments.AsQueryable());

所以新代码如下所示：

这有意义吗，是回旋处，还是有什么好办法？

public async Task<IEnumerable<DepartmentDto>> GetAllDepartments()
{
    var departments = await departmentRepository.GetAll().ToListAsync();
    Paged<Department> departmentPaged = new Paged<Department>(departments.AsQueryable());
    var departments2 = departmentPaged.GetPage(1, 3);
    var departmentDto = mapper.Map<IEnumerable<Department>, IEnumerable<DepartmentDto>>(departments2);
    return  departmentDto;
    }

也在研究这个：IQueryable does not contain definition for GetAwaiter

其他参考代码：

基础存储库和其他选项（公司的架构师想要通用存储库，而不是我的电话）：

    public IQueryable<T> GetAll()
    {
        return All;
    }
    public List<T> GetAllList()
    {
        return All.ToList();
    }

    public List<T> GetAllList(Expression<Func<T, bool>> predicate)
    {
        return All.Where(predicate).ToList();
    }

    public async Task<List<T>> GetAllListAsync()
    {
        return await All.ToListAsync();
    }

分页方式：

    public IEnumerable<T> GetPage(int index, int limit)
    {
        return source.Skip((index - 1) * limit)
            .Take(limit);
    }

Answer 1

虽然我认为在通用存储库接口中公开 IQueryable<T> 是完全失败的，但我认为你不能反对这一点。

看来你可以改写成：

public IEnumerable<DepartmentDto> GetAllDepartments()
{
    var departmentPaged = new Paged<Department>(departmentRepository.GetAll());
    return mapper.Map<IEnumerable<Department>, IEnumerable<DepartmentDto>>(departmentPaged.GetPage(1, 3));
}

其中不涉及异步代码。

如果您仍想强制将返回类型包装在任务中，您可以这样做：

public Task<IEnumerable<DepartmentDto>> GetAllDepartments()
{
    var departmentPaged = new Paged<Department>(departmentRepository.GetAll());
    return Task.FromResult(mapper.Map<IEnumerable<Department>, IEnumerable<DepartmentDto>>(departmentPaged.GetPage(1, 3)));
}