A set of extensions for optimizing/simplifying System.Threading.Channels usage.
First Channels V7 release.
Final release for Channels V6.
Added snupkg.
Updated references with some improved instances of .ConfigureAwait(false)
.
IAsyncEnumerable<T> ReadAllAsync<T>()
, I decided to expose .AsAsyncEnumerable()
as an alternative for .NET Standard 2.1 users..ToChannel<T>()
extension for AsyncEnumerable<T>
..Batch()
and .Join()
extensions better leverage on-demand requests from the source channel.singleReader
optional parameter is commonly available.deferredExecution
optional parameter exposed to guarantee methods can yield to the caller.