如何：使用异步方法与LINQ自定义扩展方法

Question

我有一个LINQ自定义扩展方法：

public static IEnumerable<T> DistinctBy<T, TKey>(this IEnumerable<T> items, Func<T, TKey> property) 
{ 
    return items.GroupBy(property).Select(x => x.First()); 
} 

，我使用它是这样的：

var spc = context.pcs.DistinctBy(w => w.province).Select(w => new 
      { 
       abc = w 
      }).ToList(); 

但问题是我不'不想ToList（）我想要这样的东西

var spc = await context.pcs.DistinctBy(w => w.province).Select(w => new 
      { 
       abc = w 
      }).ToListAsync(); 

With Async。但没有找到异步。如何使我的自定义方法distinctBy这样我也可以异步使用它？

Answer 1

ToListAsync()扩展方法扩展了IQueryable<T>，但是您的DistinctBy()方法正在扩展（并返回）IEnumerable<T>。

显然，ToListAsync()不适用于IEnumerable<T>，因为它使用Linq-To-Objects（内存中）并且不能潜在阻塞（不涉及I/O）。

试试这个：

public static IQueryable<T> DistinctBy<T, TKey>(this IQueryable<T> items, Expression<Func<T, TKey>> property) 
{ 
    return items.GroupBy(property).Select(x => x.First()); 
} 

请注意，我也改变了property参数从Func<>到Expression<Func<>>为了匹配Queryable.GroupBy（避免Enumerable.GroupBy）。

见MSDN