search
Found 73 packages
Microsoft.Bcl.AsyncInterfaces✓
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.
v10.0.3
↙ 3.6B / total
AsyncEnumerator
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}"); } }
v4.0.2
↙ 29.7M / total
IAsyncEnumerableIAsyncEnumeratorForEachAsyncParallelForEachAsyncasync
System.Linq.Async✓
Provides support for Language-Integrated Query (LINQ) over IAsyncEnumerable<T> sequences.
v7.0.0
↙ 311.9M / total
LINQasyncstreamsquery
pkg
MongoAsyncEnumerableAdapter
Provides an adapter from MongoDB's IAsyncCursor and IAsyncCursorSource to IAsyncEnumerable
v1.0.0
↙ 1.3M / total
mongodbmongolinqasync
pkg
MongoDB.Driver.Linq.AsyncEnumerable
Unofficial IAsyncEnumerable support for MongoDB C# Driver.
v2.15.4
↙ 92.9K / total
MongoDBAsyncEnumerableIAsyncEnumerable
pkg
AsyncEnumerable
IAsyncEnumerable interface definition, and some LINQ function for it
v1.0.17
↙ 162.0K / total
C#.netcollectionsequenceenumerable
FSharp.Control.TaskSeq
This library brings C#'s concept of 'await foreach' to F#, with a seamless implementation of IAsyncEnumerable<'T>. The 'taskSeq' computation expression adds support for awaitable asynchronous sequences with similar ease of use and performance to F#'s 'task' CE, with minimal overhead through ValueTask under the hood. TaskSeq brings 'seq' and 'task' together in a safe way. Generates optimized IL code through resumable state machines, and comes with a comprehensive set of functions in module 'TaskSeq'. See README for documentation and more info.
v0.4.0
↙ 542.6K / total
taskseqf#fsharpasyncseqseq
Theraot.Core✓
Theraot.Core is a .NET Backport (ValueTask, ValueTuple, Task, Expressions, Linq, ThreadLocal, IsExternalInit, Range, Index, etc...) for .NET Framework. .NET Core, .NET Standard
v3.2.11
↙ 664.4K / total
BackportPolyfillBridgeValueTaskValueTuple
pkg
CXuesong.AsyncEnumerableExtensions✓
Compatible asynchronous generator methods helper. Use built-in IAsyncEnumerable on .NET Standard 2.1, and IAsyncEnumerable in Ix.Async on prior versions.
v0.2.0
↙ 120.9K / total
pkg
akarnokd.async-enumerable-dotnet
Experimental operators for the C# 8 IAsyncEnumerables.
v0.0.4
↙ 191.7K / total
asyncconcurrencyasync-enumerableoperatorsasync-sequence
pkg
CSRakowski.AsyncStreamsPreparations
Quick helper library containing interfaces and classes to help you prepare for the C# 8 Async Streams feature.
v1.6.0
↙ 61.4K / total
C#8AsyncStreamsIAsyncEnumerableIAsyncDisposable
pkg
Wolfgang.Extensions.IAsyncEnumerable
A collection of extension methods for IAsyncEnumerable
v0.1.0
↙ 262 / total
pkg
SafeParallelAsync
This is a micro library that solves a single problem: How to run a large number of async tasks in parallel without running too many at the same time - and without running out of memory.
v0.3.0
↙ 47.1K / total
LinqIEnumerableIAsyncEnumerableAsyncTask
pkg
MoreAsyncLINQ
Additional async LINQ to objects operators for IAsyncEnumerable<T>
v3.0.0
↙ 1.8M / total
linqasync
pkg
EagerAsyncEnumerable
Provides an easy means of eagerly iterating over an IAsyncEnumerable before it is consumed.
v1.0.1
↙ 1.5K / total
asyncIAsyncEnumerable
pkg
UtilPack.AsyncEnumeration
Library containing IAsyncEnumerable, and async LINQ methods.
v1.0.1
↙ 29.8K / total
utilityasyncenumerableenumerator
AsyncEnumerable.Portable
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}"); } }
v4.1.1
↙ 26.3K / total
pkg
AsyncLinqR
A library that extends Linq's methods for IAsyncEnumerable<T>. It allows to work asynchronously. The library supports CancellationToken to be able to cancel processing.
v1.3.2
↙ 11.5K / total
LinqasyncawaitasynchronousTask
pkg
ListenableAsyncEnumerable
`ListenableAsyncEnumerable` is a C# implementation of [Dart](https://dart.dev)s `Stream` infrastructure. It adds functionality to `IAsyncEnumerable` instances to be able to listen to the data emitted by them.
v1.0.0
↙ 375 / total
IAsyncEnumerableAsyncEnumerableListen
pkg
NiceExtensions.Enumerable
This contains helpful extensions for IEnumerable and IAsyncEnumerable as well as IEnumerable<Task> extensions for easy parallelization
v1.3.0
↙ 5.7K / total
IEnumerableParallelTaskTasksExtensions
page 1next →