refactor: Remove NET6.0+ conditionals for IAsyncEnumerable support

- Add Microsoft.Bcl.AsyncInterfaces 6.0.0 package for netstandard2.0
- Remove all #if NET6_0_OR_GREATER conditionals from IAsyncEnumerable code
- Make ProcessInParallel and other async enumerable extensions available for all target frameworks
- This enables IAsyncEnumerable support across all framework targets

🤖 Generated with [Claude Code](https://claude.ai/code)

Co-Authored-By: Claude <[email protected]>

Author: thomhurst

EnumerableAsyncProcessor.Example/ProcessInParallelExample.cs

@@ -17,9 +17,9 @@ public static async Task RunExample()
         Console.WriteLine("====================================\n");
 
         // Example 1: Simple parallel processing without transformation
-        Console.WriteLine("Example 1: Simple parallel processing");
+        Console.WriteLine("Example 1: Simple parallel processing (no transformation needed!)");
         var asyncEnumerable1 = GenerateAsyncEnumerable(5);
-        var results1 = await asyncEnumerable1.ProcessInParallel();
+        IEnumerable<int> results1 = await asyncEnumerable1.ProcessInParallel();  // <-- This is the simple extension!
         Console.WriteLine($"Results: {string.Join(", ", results1)}");
 
         // Example 2: Parallel processing with transformation

EnumerableAsyncProcessor/Builders/AsyncEnumerableActionAsyncProcessorBuilder_1.cs

@@ -1,4 +1,3 @@
-#if NET6_0_OR_GREATER
 using EnumerableAsyncProcessor.Extensions;
 using EnumerableAsyncProcessor.RunnableProcessors.AsyncEnumerable;
 
@@ -92,5 +91,4 @@ public IAsyncEnumerableProcessor ProcessInBatches(int batchSize)
             _items, _taskSelector, batchSize, _cancellationTokenSource);
     }
 
-}
-#endif
+}

EnumerableAsyncProcessor/Builders/AsyncEnumerableActionAsyncProcessorBuilder_2.cs

@@ -1,4 +1,3 @@
-#if NET6_0_OR_GREATER
 using EnumerableAsyncProcessor.Extensions;
 using EnumerableAsyncProcessor.RunnableProcessors.AsyncEnumerable.ResultProcessors;
 
@@ -92,5 +91,4 @@ public IAsyncEnumerableProcessor<TOutput> ProcessInBatches(int batchSize)
             _items, _taskSelector, batchSize, _cancellationTokenSource);
     }
 
-}
-#endif
+}

EnumerableAsyncProcessor/Builders/AsyncEnumerableAsyncProcessorBuilder.cs

@@ -1,4 +1,3 @@
-#if NET6_0_OR_GREATER
 namespace EnumerableAsyncProcessor.Builders;
 
 public class AsyncEnumerableAsyncProcessorBuilder<TInput>
@@ -35,5 +34,4 @@ public AsyncEnumerableActionAsyncProcessorBuilder<TInput> ForEachAsync(
     {
         return new AsyncEnumerableActionAsyncProcessorBuilder<TInput>(_items, taskSelector, cancellationToken);
     }
-}
-#endif
+}

EnumerableAsyncProcessor/EnumerableAsyncProcessor.csproj

@@ -21,7 +21,7 @@
         <ContinuousIntegrationBuild>true</ContinuousIntegrationBuild>
     </PropertyGroup>
 
-    <ItemGroup Condition="'$(TargetFrameworkIdentifier)'!='.NETCoreApp'">
+    <ItemGroup Condition="'$(TargetFramework)' == 'netstandard2.0'">
         <PackageReference Include="Microsoft.Bcl.AsyncInterfaces" Version="6.0.0" />
     </ItemGroup>
 

EnumerableAsyncProcessor/Extensions/AsyncEnumerableExtensions.cs

@@ -1,4 +1,3 @@
-#if NET6_0_OR_GREATER
 using EnumerableAsyncProcessor.Builders;
 
 namespace EnumerableAsyncProcessor.Extensions;
@@ -222,5 +221,4 @@ public static async Task<IEnumerable<TOutput>> ProcessInParallel<T, TOutput>(
 
         return results;
     }
-}
-#endif
+}

EnumerableAsyncProcessor/Interfaces/IAsyncEnumerableProcessor.cs

@@ -1,4 +1,3 @@
-#if NET6_0_OR_GREATER
 namespace EnumerableAsyncProcessor.Extensions;
 
 public interface IAsyncEnumerableProcessor
@@ -9,5 +8,4 @@ public interface IAsyncEnumerableProcessor
 public interface IAsyncEnumerableProcessor<TOutput>
 {
     IAsyncEnumerable<TOutput> ExecuteAsync();
-}
-#endif
+}

EnumerableAsyncProcessor/RunnableProcessors/AsyncEnumerable/AsyncEnumerableBatchProcessor.cs

@@ -1,4 +1,3 @@
-#if NET6_0_OR_GREATER
 using EnumerableAsyncProcessor.Extensions;
 
 namespace EnumerableAsyncProcessor.RunnableProcessors.AsyncEnumerable;
@@ -50,5 +49,4 @@ private async Task ProcessBatch(List<TInput> batch, CancellationToken cancellati
         var tasks = batch.Select(item => _taskSelector(item)).ToArray();
         await Task.WhenAll(tasks).ConfigureAwait(false);
     }
-}
-#endif
+}

EnumerableAsyncProcessor/RunnableProcessors/AsyncEnumerable/AsyncEnumerableOneAtATimeProcessor.cs

@@ -1,4 +1,3 @@
-#if NET6_0_OR_GREATER
 using EnumerableAsyncProcessor.Extensions;
 
 namespace EnumerableAsyncProcessor.RunnableProcessors.AsyncEnumerable;
@@ -31,5 +30,4 @@ public async Task ExecuteAsync()
             await _taskSelector(item).ConfigureAwait(false);
         }
     }
-}
-#endif
+}

EnumerableAsyncProcessor/RunnableProcessors/AsyncEnumerable/AsyncEnumerableParallelProcessor.cs

@@ -1,4 +1,3 @@
-#if NET6_0_OR_GREATER
 using EnumerableAsyncProcessor.Extensions;
 
 namespace EnumerableAsyncProcessor.RunnableProcessors.AsyncEnumerable;
@@ -94,5 +93,4 @@ public async Task ExecuteAsync()
             }
         }
     }
-}
-#endif
+}