Fixed issue with async inferrence.

Author: Oren (electricessence)

Open.ChannelExtensions/Extensions.Read.cs

@@ -244,7 +244,7 @@ public static ValueTask<long> ReadAllAsync<TWrite, TRead>(this Channel<TWrite, T
 		/// <param name="cancellationToken">An optional cancellation token.</param>
 		/// <returns>A task containing the count of items read that completes when no more reading is to be done.
 		/// The count should be ignored if the number of iterations could exceed the max value of long.</returns>
-		public static ValueTask<long> ReadAllAsync<TWrite, TRead>(this Channel<TWrite, TRead> channel,
+		public static ValueTask<long> TaskReadAllAsync<TWrite, TRead>(this Channel<TWrite, TRead> channel,
 			Func<TRead, long, Task> receiver,
 			CancellationToken cancellationToken = default)
 			=> channel.Reader.ReadAllAsync((e, i) => new ValueTask(receiver(e, i)), cancellationToken);
@@ -272,7 +272,7 @@ public static ValueTask<long> ReadAllAsync<T>(this ChannelReader<T> reader,
 		/// <param name="cancellationToken">An optional cancellation token.</param>
 		/// <returns>A task containing the count of items read that completes when no more reading is to be done.
 		/// The count should be ignored if the number of iterations could exceed the max value of long.</returns>
-		public static ValueTask<long> ReadAllAsync<T>(this ChannelReader<T> reader,
+		public static ValueTask<long> TaskReadAllAsync<T>(this ChannelReader<T> reader,
 			Func<T, Task> receiver,
 			CancellationToken cancellationToken = default)
 			=> reader.ReadAllAsync((e, i) => new ValueTask(receiver(e)), cancellationToken);
@@ -286,7 +286,7 @@ public static ValueTask<long> ReadAllAsync<T>(this ChannelReader<T> reader,
 		/// <param name="cancellationToken">An optional cancellation token.</param>
 		/// <returns>A task containing the count of items read that completes when no more reading is to be done.
 		/// The count should be ignored if the number of iterations could exceed the max value of long.</returns>
-		public static ValueTask<long> ReadAllAsync<TWrite, TRead>(this Channel<TWrite, TRead> channel,
+		public static ValueTask<long> TaskReadAllAsync<TWrite, TRead>(this Channel<TWrite, TRead> channel,
 			Func<TRead, Task> receiver,
 			CancellationToken cancellationToken = default)
 			=> channel.Reader.ReadAllAsync((e, i) => new ValueTask(receiver(e)), cancellationToken);

Open.ChannelExtensions/Extensions.ReadConcurrently.cs

@@ -54,6 +54,21 @@ public static Task<long> ReadAllConcurrentlyAsync<T>(this ChannelReader<T> reade
 			ValueTask ParallelReceiver(T item, long i) => receiver(item);
 		}
 
+		/// <summary>
+		/// Reads items from the channel and passes them to the receiver.
+		/// </summary>
+		/// <typeparam name="T">The item type.</typeparam>
+		/// <param name="reader">The channel reader to read from.</param>
+		/// <param name="maxConcurrency">The maximum number of concurrent operations.</param>
+		/// <param name="receiver">The async receiver function.</param>
+		/// <param name="cancellationToken">An optional cancellation token.</param>
+		/// <returns>A task that completes when no more reading is to be done.</returns>
+		public static Task<long> TaskReadAllConcurrentlyAsync<T>(this ChannelReader<T> reader,
+			int maxConcurrency,
+			Func<T, Task> receiver,
+			CancellationToken cancellationToken = default)
+			=> reader.ReadAllConcurrentlyAsync(maxConcurrency, item => new ValueTask(receiver(item)), cancellationToken);
+
 		/// <summary>
 		/// Reads items from the channel and passes them to the receiver.
 		/// </summary>
@@ -78,7 +93,7 @@ public static Task<long> ReadAllConcurrentlyAsync<TWrite, TRead>(this Channel<TW
 		/// <param name="receiver">The async receiver function.</param>
 		/// <param name="cancellationToken">An optional cancellation token.</param>
 		/// <returns>A task that completes when no more reading is to be done.</returns>
-		public static Task<long> ReadAllConcurrentlyAsync<TWrite, TRead>(this Channel<TWrite, TRead> channel,
+		public static Task<long> TaskReadAllConcurrentlyAsync<TWrite, TRead>(this Channel<TWrite, TRead> channel,
 			int maxConcurrency,
 			Func<TRead, Task> receiver,
 			CancellationToken cancellationToken = default)

Open.ChannelExtensions/Open.ChannelExtensions.csproj

@@ -16,10 +16,10 @@ Part of the "Open" set of libraries.</Description>
     <RepositoryType>git</RepositoryType>
     <PackageTags>channels dotnet threading tasks extensions</PackageTags>
     <GeneratePackageOnBuild>true</GeneratePackageOnBuild>
-    <Version>2.3.2</Version>
+    <Version>2.3.3</Version>
     <PackageLicenseExpression>MIT</PackageLicenseExpression>
-    <AssemblyVersion>2.3.2.0</AssemblyVersion>
-    <FileVersion>2.3.2.0</FileVersion>
+    <AssemblyVersion>2.3.3.0</AssemblyVersion>
+    <FileVersion>2.3.3.0</FileVersion>
     <PackageReleaseNotes></PackageReleaseNotes>
   </PropertyGroup>