Wywołanie metody asynchronicznej w IEnumerable.Select

Question

Mam następujący kod, przeliczenia pozycji pomiędzy rodzajami R i L stosując metodę transmisji asynchronicznej:

class MyClass<R,L> { 

    public async Task<bool> MyMethodAsync(List<R> remoteItems) { 
     ... 

     List<L> mappedItems = new List<L>(); 
     foreach (var remoteItem in remoteItems) 
     { 
      mappedItems.Add(await MapToLocalObject(remoteItem)); 
     } 

     //Do stuff with mapped items 

     ... 
    } 

    private async Task<L> MapToLocalObject(R remoteObject); 
} 

Czy to możliwe, aby napisać używając połączenia IEnumerable.Select (lub podobny), aby zmniejszyć linie kodu? Próbowałem to:

class MyClass<R,L> { 

    public async Task<bool> MyMethodAsync(List<R> remoteItems) { 
     ... 

     List<L> mappedItems = remoteItems.Select<R, L>(async r => await MapToLocalObject(r)).ToList<L>(); 

     //Do stuff with mapped items 

     ... 
    } 
} 

ale pojawia się błąd:

"Cannot convert async lambda expression to delegate type 'System.Func<R,int,L>' . An async lambda expression may return void , Task or Task<T> , none of which are convertible to 'System.Func<R,int,L>' ."

Wierzę, że jestem brakuje czegoś o async/czekają na słowa kluczowe, ale nie mogę dowiedzieć się, co. Czy jakikolwiek organ wie, w jaki sposób mogę zmodyfikować mój kod, aby działał?

Answer 1

Możesz to rozwiązać, biorąc pod uwagę typy w grze. Na przykład: MapToLocalObject - w trybie asynchronicznym - mapuje z R na L. Ale jeśli widzisz to jako funkcję synchroniczną, mapuje ona od R do Task<L>.

Task jest „przyszłość”, więc Task<L> można traktować jako rodzaj że będzie wytworzenia L w pewnym momencie w przyszłości.

Więc można łatwo przekonwertować z sekwencji R do sekwencji Task<L>:

IEnumerable<Task<L>> mappingTasks = remoteItems.Select(remoteItem => MapToLocalObject(remoteItem)); 

Należy pamiętać, że istnieje istotna różnica między tym semantyczny i oryginalnego kodu. Twój oryginalny kod czeka na zmapowanie każdego obiektu przed przejściem do następnego obiektu; ten kod rozpocznie wszystkie odwzorowania jednocześnie.

Twój wynik to sekwencja zadań - sekwencja przyszłych wyników L. Aby pracować z sekwencjami zadań, istnieje kilka typowych operacji. Task.WhenAll i Task.WhenAny są wbudowanymi funkcjami spełniającymi najczęstsze wymagania. Jeśli chcesz czekać, aż wszystkie mapowania zostały zakończone, można zrobić:

L[] mappedItems = await Task.WhenAll(mappingTasks); 

Jeśli wolisz, aby obsłużyć każdą pozycję jako jej zakończeniem, można użyć OrderByCompletion z my AsyncEx library:

Task<L>[] orderedMappingTasks = mappingTasks.OrderByCompletion(); 
foreach (var task in orderedMappingTasks) 
{ 
    var mappedItem = await task; 
    ... 
}