AsyncEnumerator 1.1.2
Introduces IAsyncEnumerable, IAsyncEnumerator, ForEachAsync(), and ParallelForEachAsync()
GitHub: https://github.com/tyrotoxin/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 System.Collections.Async;
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()
{
// NOTE: IAsyncEnumerable is derived from IEnumerable, so you can use either
var enumerableCollection = ProduceAsyncNumbers(start: 1, end: 10);
//var enumerableCollection = ProduceNumbers(start: 1, end: 10);
foreach (var number in enumerableCollection) {
Console.Out.WriteLine($"{number}");
}
}
See the version list below for details.
Release Notes
Add ParallelForEachAsync extension methods for IEnumerable<T> and IAsyncEnumerable<T> in System.Collections.Async namespace.
Dependencies
This package has no dependencies.
Version History
Version | Downloads | Last updated | |
---|---|---|---|
2.2.2 | 2,741 | 1/27/2019 | |
2.2.1 | 140,811 | 5/29/2018 | |
2.2.0 | 7,298 | 5/18/2018 | |
2.1.1 | 57,435 | 1/20/2018 | |
2.1.0 | 120,847 | 5/22/2017 | |
2.0.1 | 38,363 | 2/13/2017 | |
1.5.0 | 2,571 | 2/12/2017 | |
1.4.2 | 903 | 2/6/2017 | |
1.3.0 | 1,184 | 1/20/2017 | |
1.2.3 | 6,198 | 1/6/2017 | |
1.2.2 | 1,020 | 12/11/2016 | |
1.2.1 | 263 | 12/10/2016 | |
1.2.0 | 7,676 | 11/29/2016 | |
1.1.3 | 276 | 11/28/2016 | |
1.1.2 | 12,040 | 8/29/2016 | |
1.0.3 | 1,419 | 4/28/2016 |