AsyncEnumerable icon indicating copy to clipboard operation
AsyncEnumerable copied to clipboard

Defines IAsyncEnumerable, IAsyncEnumerator, ForEachAsync(), ParallelForEachAsync(), and other useful stuff to use with async-await

Results 26 AsyncEnumerable issues
Sort by recently updated
recently updated
newest added

This code/app has been in place for years. Updated the Microsoft.Bcl.AsyncInterfaces from 1.0.0.0 to 5.0.0.0 and the app hangs in ParallelForEachAsync call. ` var results = new ConcurrentBag(); await plogs.ParallelForEachAsync(async...

I would like to use a parallel loop for `N` number of calls to a service, to execute them in batches, and avoid DoS-ing the service. I had previously created...

it would be nice to be able to inherit from AsyncEnumerable. the ability to return the object pointer instead of a new object for the enumerator would offer a savings...

ParallelForEachAsync sometimes does not throw an exception if individual iterations did throw exceptions. It reproduces with the following code (derived from the scenario where I noticed it): ``` while (true)...

Not resetting exception list to null in ReadExceptions, so that in case multiple tasks are finishing at the same time they will all read a non-empty list of exceptions. Returning...

I have used this library for quite some time and just recently I met TPL's ActionBlock. I wanted to know if someone has any input on differences and such. Thanks!

Great library by the way! Super helpful! Thank you so much :) Just a small thing BTW, Step 3 of the implementation documentation says: >To avoid performance degradation and possible...

```c# using Dasync.Collections; var booking = _dbContext.Bookings.SingleAsync(b => b.Id == id, cancellationToken); ``` This will result in the booking sometimes being grabbed, but in most cases it seems like much...

I have used this successfully in .net core web api. works like a charm. I am currently updating some older .net framework 4.7 WCF, converting the class libraries to .net...

Hi there! For some reason I used `ToEnumerable()` extension to iterate `IAsyncEnumerable` synchronously. And for sure I got the exception from [this line](https://github.com/Dasync/AsyncEnumerable/blob/master/src/Internals/EnumeratorAdapter.cs#L41) of code. [Documentation](https://docs.microsoft.com/en-us/dotnet/api/system.threading.tasks.valuetask-1?view=netcore-3.0) tells us that this...