Found 95 packages
Provides the IAsyncEnumerable<T> and IAsyncDisposable interfaces and helper types for .NET Standard 2.0. This package is not required starting with .NET Standard 2.1 and .NET Core 3.0.
Provides support for Language-Integrated Query (LINQ) over IAsyncEnumerable<T> sequences.
Interactive Extensions Async Library used to express queries over asynchronous enumerable sequences.
Introduces IAsyncEnumerable, IAsyncEnumerator, ForEachAsync(), and ParallelForEachAsync() GitHub: https://github.com/Dasync/AsyncEnumerable PROBLEM SPACE Helps to (a) create an element provider, where producing an element can take a lot of time due to dependency on other asynchronous events (e.g. wait handles, network streams), and (b) a consumer that processes those element as soon as they are ready without blocking the thread (the processing is scheduled on a worker thread instead). EXAMPLE using Dasync.Collections; static IAsyncEnumerable<int> ProduceAsyncNumbers(int start, int end) { return new AsyncEnumerable<int>(async yield => { // Just to show that ReturnAsync can be used multiple times await yield.ReturnAsync(start); for (int number = start + 1; number <= end; number++) await yield.ReturnAsync(number); // You can break the enumeration loop with the following call: yield.Break(); // This won't be executed due to the loop break above await yield.ReturnAsync(12345); }); } // Just to compare with synchronous version of enumerator static IEnumerable<int> ProduceNumbers(int start, int end) { yield return start; for (int number = start + 1; number <= end; number++) yield return number; yield break; yield return 12345; } static async Task ConsumeNumbersAsync() { var asyncEnumerableCollection = ProduceAsyncNumbers(start: 1, end: 10); await asyncEnumerableCollection.ForEachAsync(async number => { await Console.Out.WriteLineAsync($"{number}"); }); } // Just to compare with synchronous version of enumeration static void ConsumeNumbers() { var enumerableCollection = ProduceNumbers(start: 1, end: 10); foreach (var number in enumerableCollection) { Console.Out.WriteLine($"{number}"); } }
System.Collections.Async.
System.Linq.AsyncEnumerable
Interactive Extensions Async Providers Library used to build query providers and express queries over async enumerable sequences.
Various Enumerable Async Processors - Batch / Parallel / Rate Limited / One at a time
Provides an adapter from MongoDB's IAsyncCursor and IAsyncCursorSource to IAsyncEnumerable
Additional async LINQ to objects operators for IAsyncEnumerable<T>
C# LINQ Async extension methods library for async/await task.
IAsyncEnumerable interface definition, and some LINQ function for it
Experimental operators for the C# 8 IAsyncEnumerables.
A collection of helpful AsyncEnumerable extension methods
This Package contains a helper async builder that allow building AsyncEnumerable from Paged datasource and list of tasks
Compatible asynchronous generator methods helper. Use built-in IAsyncEnumerable on .NET Standard 2.1, and IAsyncEnumerable in Ix.Async on prior versions.
Unofficial IAsyncEnumerable support for MongoDB C# Driver.
This package contains a extension methods for primitives and async enumerables.
This package contains a extension methods for unions and async enumerables.