Add override on SelectManyAsync

Author: pascal-libaud

changelog.md

@@ -40,3 +40,7 @@ Initial version.
 ## 1.3.0
 
 Add support for ConfigureAwait(false)
+
+## 1.3.1
+
+Add override on SelectManyAsync

src/AsyncLinqR/SelectManyAsync.cs

@@ -2,6 +2,10 @@
 
 public static partial class AsyncLinq
 {
+    // TODO Reprendre tous les appels avec IEnumerable<TResult> et les dupliquer avec TResult[] et List<TResult>
+    // TODO Faire un test qui garantit qu'on n'ait pas d'ambiguité sur les appels sans devoir spécifier les types génériques
+    // TODO Valider qu'on est bien avec List et array
+
     public static async IAsyncEnumerable<TResult> SelectManyAsync<T, TResult>(this IAsyncEnumerable<T> source, Func<T, IEnumerable<TResult>> selector, [EnumeratorCancellation] CancellationToken cancellationToken = default)
     {
         await foreach (var item in source.WithCancellation(cancellationToken).ConfigureAwait(false))
@@ -23,6 +27,17 @@ public static async IAsyncEnumerable<TResult> SelectManyAsync<T, TResult>(this I
             }
     }
 
+    public static async IAsyncEnumerable<TResult> SelectManyAsync<T, TResult>(this IEnumerable<T> source, Func<T, Task<TResult[]>> selector, [EnumeratorCancellation] CancellationToken cancellationToken = default)
+    {
+        cancellationToken.ThrowIfCancellationRequested();
+        foreach (var item in source)
+        foreach (var result in await selector(item).ConfigureAwait(false))
+        {
+            cancellationToken.ThrowIfCancellationRequested();
+            yield return result;
+        }
+    }
+
     public static async IAsyncEnumerable<TResult> SelectManyAsync<T, TResult>(this IAsyncEnumerable<T> source, Func<T, Task<IEnumerable<TResult>>> selector, [EnumeratorCancellation] CancellationToken cancellationToken = default)
     {
         await foreach (var item in source.WithCancellation(cancellationToken).ConfigureAwait(false))

src/AsyncLinqR/_Todo.cs

@@ -8,4 +8,6 @@
 // GroupJoin
 
 // Nouveautés .Net 9
-// Enumerable.CountBy, AggregateBy
+// Enumerable.CountBy, AggregateBy
+
+// Autre : cf SelectManyAsync