Как использовать асинхронную лямбду с помощью SelectMany?

Question

Я получаю следующее сообщение об ошибке при попытке использовать async лямбда в IEnumerable.SelectMany:

var result = myEnumerable.SelectMany(async (c) => await Functions.GetDataAsync(c.Id)); 

аргументы типа для метода «IEnumerable System.Linq.Enumerable.SelectMany (это IEnumerable, Func>) 'не может быть выведено из использования. Попробуйте указать аргументы типа явно

Где GetDataAsync определяется как:

public interface IFunctions { 
    Task<IEnumerable<DataItem>> GetDataAsync(string itemId); 
} 

public class Functions : IFunctions { 
    public async Task<IEnumerable<DataItem>> GetDataAsync(string itemId) { 
     // return await httpCall(); 
    } 
} 

Я предполагаю, потому что мой GetDataAsync метод фактически возвращает Task<IEnumerable<T>>. Но почему работает Select, наверняка он должен бросить ту же ошибку?

var result = myEnumerable.Select(async (c) => await Functions.GetDataAsync(c.Id)); 

Есть ли способ обойти это?

Answer 1

выражение async лямбда не может быть преобразовано в простой Func<TSource, TResult>.

Таким образом, многие из них не могут быть использованы. Вы можете работать в синхронном контексте:

myEnumerable.Select(c => Functions.GetDataAsync(c.Id)).SelectMany(task => task.Result); 

или

List<DataItem> result = new List<DataItem>(); 

foreach (var ele in myEnumerable) 
{ 
    result.AddRange(await Functions.GetDataAsyncDo(ele.Id)); 
} 

Вы не можете ни использовать yield return - это дизайн. f.e .:

public async Task<IEnuemrable<DataItem>> Do() 
{ 
    ... 
    foreach (var ele in await Functions.GetDataAsyncDo(ele.Id)) 
    { 
     yield return ele; // compile time error, async method 
          // cannot be used with yield return 
    } 

} 

Answer 2

Это расширение:

public static async Task<IEnumerable<T1>> SelectManyAsync<T, T1>(this IEnumerable<T> enumeration, Func<T, Task<IEnumerable<T1>>> func) 
{ 
    return (await Task.WhenAll(enumeration.Select(func))).SelectMany(s => s); 
} 

Это позволяет запускать:

var result = await myEnumerable.SelectManyAsync(c => Functions.GetDataAsync(c.Id)); 

Объяснение: у вас есть список задач, каждая из которых возвращает Task<IEnumerable<T>>. Поэтому вам нужно уволить их всех, а затем ждать, а затем раздавать результат через SelectMany.

Answer 3

Select работает, потому что он вернет IEnumerable<Task<T>>, который затем можно ожидать, например. Task.WhenAll.

Таким образом, простое решение этой проблемы:

IEnumerable<Task<IEnumerable<T>>> tasks = source.Select(GetNestedEnumerableTask); 
IEnumerable<T>[] nestedResults = await Task.WhenAll(tasks); 
IEnumerable<T> results = nestedResults.SelectMany(nr => nr);