diff --git a/csharp/Lib/Utils/AsyncEnumerableEx.cs b/csharp/Lib/Utils/AsyncEnumerableEx.cs index ffd069bdf..5bfc21015 100644 --- a/csharp/Lib/Utils/AsyncEnumerableEx.cs +++ b/csharp/Lib/Utils/AsyncEnumerableEx.cs @@ -5,6 +5,12 @@ namespace InnovEnergy.Lib.Utils; public static class AsyncEnumerableEx { + public static IAsyncEnumerable SelectMany(this IAsyncEnumerable ts, Func> map) + { + return ts.SelectMany(t => map(t).ToAsyncEnumerable()); + } + + public static async IAsyncEnumerable Throttle(this IAsyncEnumerable ts, TimeSpan dueTime, [EnumeratorCancellation] CancellationToken cancel = default) diff --git a/csharp/Lib/Utils/Utils.csproj b/csharp/Lib/Utils/Utils.csproj index 94dac3941..88d6cc0cc 100644 --- a/csharp/Lib/Utils/Utils.csproj +++ b/csharp/Lib/Utils/Utils.csproj @@ -1,8 +1,4 @@ - - Debug;Release;Release-Server - AnyCPU;linux-arm - @@ -12,6 +8,7 @@ +