The Interactive Extensions (Ix) is a .NET library which extends LINQ to Objects, and provides many of the operators available in Rx but targeted for IEnumerable
Questions tagged [ix.net]
5 questions
6
votes
3 answers
Merge multiple IAsyncEnumerable streams
With the release of Mediatr 10, there's now a paradigm that allows developers to create streams powered by IAsyncEnumerable. I'm leveraging this paradigm to create multiple different file system watchers to monitor multiple folders. To monitor the…
JD Davis
- 3,517
- 4
- 28
- 61
4
votes
3 answers
How to merge multiple asynchronous sequences without left-side bias?
I have a few AsyncEnumerables that I would like to merge in a single AsyncEnumerable, which should contain all the elements that are emitted concurrently from those sequences. So I used the Merge operator from the…
Theodor Zoulias
- 34,835
- 7
- 69
- 104
3
votes
1 answer
How does cancellation work for IAsyncEnumerable.ToArrayAsync()?
I working with AsyncEnumerables to read a bunch of files into my C# application (.NET 6) and want to add an option to cancel reading. However I'm confused by the behaviour of ToArrayAsync when provided with a cancellationToken.
I tried to break it…
Simoris
- 51
- 4
2
votes
1 answer
How to Zip concurrently two IAsyncEnumerables?
I have two asynchronous sequences that I want to "zip" in pairs, and for this purpose I used the Zip operator from the System.Linq.Async package. This operator behaves in an undesirable way though, at least for my case. Instead of enumerating the…
Theodor Zoulias
- 34,835
- 7
- 69
- 104
0
votes
1 answer
How to use WhereAwait from System.Linq.Async with custom bools
I have a database and I make a lot of Where calls to it to make a table in Blazor. This takes long because Where is not Async. To speed this up I wanted to change the Where statements by using: ToAsyncEnumerable().WhereAwait from…
Harold Vandeputte
- 31
- 7