Unified sync/async stream processing with category-based filtering. Single API for IEnumerable/IAsyncEnumerable with Cases/SelectCase/ForEachCase pattern. Eliminates Rx complexity, enables elegant pipeline composition for real-time data processing.
csharp functional-programming dotnet reactive-programming stream-processing async-await event-processing data-streaming linq-extensions async-enumerable fluent-api category-filtering pipeline-composition- observables-alternative
-
Updated
Sep 9, 2025 - C#