Premières méthodes de tests pour valider que l'inférence de type fonctionne bien à la compilation et que la valeur de retour est comme attendue

Ajout de méthodes dans SelectManyAsync

Author: pascal-libaud

src/AsyncLinqR.Tests/SelectManyAsyncTest.cs

@@ -0,0 +1,84 @@
+using System.Linq;
+
+namespace AsyncLinqR.Tests;
+
+public class SelectManyAsyncTest
+{
+    // TODO Renommer tous les tests pour donner des noms parlants
+    [Fact]
+    public async Task Suite()
+    {
+        var enumerable = await Fake<IEnumerable<int>>.Create([]).SelectManyAsync(x => x.List).ToListAsync();
+        enumerable.Should().BeOfType<List<int>>();
+
+        var array = await Fake<int[]>.Create([]).SelectManyAsync(x => x.List).ToListAsync();
+        array.Should().BeOfType<List<int>>();
+
+        // TODO Rajouter List<int>
+    }
+
+    [Fact]
+    public async Task SelectAsync_patin_couffin()
+    {
+        var enumerable = await Fake<IEnumerable<int>>.CreateAsync([]).SelectManyAsync(x => x.List).ToListAsync();
+        enumerable.Should().BeOfType<List<int>>();
+
+        var array = await Fake<int[]>.CreateAsync([]).SelectManyAsync(x => x.List).ToListAsync();
+        array.Should().BeOfType<List<int>>();
+
+        // TODO Rajouter List<int>
+    }
+
+    [Fact]
+    public async Task Selector_and_async_changer_ces_noms_pourris()
+    {
+        var enumerable = await Fake<IEnumerable<int>>.CreateAsync([]).SelectManyAsync(x => x.List, (y, i) => i).ToListAsync();
+        enumerable.Should().BeOfType<List<int>>();
+
+        // TODO Rajouter int[]
+        // TODO Rajouter List<int>
+    }
+
+    [Fact]
+    public async Task Selector_and_sync_changer_ces_noms_pourris()
+    {
+        var enumerable = await Fake<IEnumerable<int>>.Create([]).SelectManyAsync(x => x.List, (y, i) => i).ToListAsync();
+        enumerable.Should().BeOfType<List<int>>();
+
+        // TODO Rajouter int[]
+        // TODO Rajouter List<int>
+    }
+
+    [Fact]
+    public async Task Selector_and_async_changer_ces_noms_pourris_toto()
+    {
+        var enumerable = await Fake<IEnumerable<int>>.CreateAsync([]).SelectManyAsync(x => x.List, (y, i) => Task<int>.Factory.StartNew(() => i)).ToListAsync();
+        enumerable.Should().BeOfType<List<int>>();
+
+        // TODO Rajouter int[]
+        // TODO Rajouter List<int>
+    }
+
+    [Fact]
+    public async Task Selector_and_sync_changer_ces_noms_pourris_toto()
+    {
+        var enumerable = await Fake<IEnumerable<int>>.Create([]).SelectManyAsync(x => x.List, (y, i) => Task<int>.Factory.StartNew(() => i)).ToListAsync();
+        enumerable.Should().BeOfType<List<int>>();
+
+        // TODO Rajouter int[]
+        // TODO Rajouter List<int>
+    }
+}
+
+record Fake<T>(int Value, Task<T> List)
+{
+    public static IEnumerable<Fake<T>> Create(T list)
+    {
+        return Enumerable.Range(0, 10).Select(x => new Fake<T>(x, Task<T>.Factory.StartNew(() => list)));
+    }
+
+    public static IAsyncEnumerable<Fake<T>> CreateAsync(T list)
+    {
+        return AsyncLinq.RangeAsync(10).SelectAsync(x => new Fake<T>(x, Task<T>.Factory.StartNew(() => list)));
+    }
+}

src/AsyncLinqR/SelectManyAsync.cs

@@ -48,6 +48,16 @@ public static async IAsyncEnumerable<TResult> SelectManyAsync<T, TResult>(this I
             }
     }
 
+    public static async IAsyncEnumerable<TResult> SelectManyAsync<T, TResult>(this IAsyncEnumerable<T> source, Func<T, Task<TResult[]>> selector, [EnumeratorCancellation] CancellationToken cancellationToken = default)
+    {
+        await foreach (var item in source.WithCancellation(cancellationToken).ConfigureAwait(false))
+        foreach (var result in await selector(item).ConfigureAwait(false))
+        {
+            cancellationToken.ThrowIfCancellationRequested();
+            yield return result;
+        }
+    }
+
     public static async IAsyncEnumerable<TResult> SelectManyAsync<T, TResult>(this IEnumerable<T> source, Func<T, IAsyncEnumerable<TResult>> selector, [EnumeratorCancellation] CancellationToken cancellationToken = default)
     {
         cancellationToken.ThrowIfCancellationRequested();
@@ -73,6 +83,16 @@ public static async IAsyncEnumerable<TResult> SelectManyAsync<T, TCollection, TR
             }
     }
 
+    public static async IAsyncEnumerable<TResult> SelectManyAsync<T, TCollection, TResult>(this IAsyncEnumerable<T> source, Func<T, Task<IEnumerable<TCollection>>> collectionSelector, Func<T, TCollection, TResult> resultSelector, [EnumeratorCancellation] CancellationToken cancellationToken = default)
+    {
+        await foreach (var item in source.WithCancellation(cancellationToken).ConfigureAwait(false))
+        foreach (var result in await collectionSelector(item).ConfigureAwait(false))
+        {
+            cancellationToken.ThrowIfCancellationRequested();
+            yield return resultSelector(item, result);
+        }
+    }
+
     public static async IAsyncEnumerable<TResult> SelectManyAsync<T, TCollection, TResult>(this IEnumerable<T> source, Func<T, Task<IEnumerable<TCollection>>> collectionSelector, Func<T, TCollection, TResult> resultSelector, [EnumeratorCancellation] CancellationToken cancellationToken = default)
     {
         cancellationToken.ThrowIfCancellationRequested();
@@ -120,6 +140,16 @@ public static async IAsyncEnumerable<TResult> SelectManyAsync<T, TCollection, TR
             }
     }
 
+    public static async IAsyncEnumerable<TResult> SelectManyAsync<T, TCollection, TResult>(this IAsyncEnumerable<T> source, Func<T, Task<IEnumerable<TCollection>>> collectionSelector, Func<T, TCollection, Task<TResult>> resultSelector, [EnumeratorCancellation] CancellationToken cancellationToken = default)
+    {
+        await foreach (var item in source.WithCancellation(cancellationToken).ConfigureAwait(false))
+        foreach (var result in await collectionSelector(item).ConfigureAwait(false))
+        {
+            cancellationToken.ThrowIfCancellationRequested();
+            yield return await resultSelector(item, result).ConfigureAwait(false);
+        }
+    }
+
     public static async IAsyncEnumerable<TResult> SelectManyAsync<T, TCollection, TResult>(this IEnumerable<T> source, Func<T, Task<IEnumerable<TCollection>>> collectionSelector, Func<T, TCollection, Task<TResult>> resultSelector, [EnumeratorCancellation] CancellationToken cancellationToken = default)
     {
         cancellationToken.ThrowIfCancellationRequested();