More flexible and useful type inferrence.

Author: Oren (electricessence)

Open.ChannelExtensions/Extensions.Transform.cs

@@ -50,5 +50,28 @@ public override ValueTask<bool> WaitToReadAsync(CancellationToken cancellationTo
 		/// <returns>A channel reader representing the tranformed results.</returns>
 		public static ChannelReader<TResult> Transform<T, TResult>(this ChannelReader<T> source, Func<T, TResult> transform)
 			=> new TransformingChannelReader<T, TResult>(source, transform);
+
+		/// <summary>
+		/// Transforms the 
+		/// </summary>
+		/// <typeparam name="TWrite">Specifies the type of data that may be written to the channel.</typeparam>
+		/// <typeparam name="TRead">Specifies the type of data read from the source channel.</typeparam>
+		/// <typeparam name="TResult">Specifies the type of data that may be read from the channel.</typeparam>
+		/// <param name="source">The source channel reader.</param>
+		/// <param name="transform">The transform function.</param>
+		/// <returns>A channel reader representing the tranformed results.</returns>
+		public static TransformChannel<TWrite, TRead, TResult> Transform<TWrite, TRead, TResult>(this Channel<TWrite, TRead> source, Func<TRead, TResult> transform)
+			=> new TransformChannel<TWrite, TRead, TResult>(source, transform);
+
+		/// <summary>
+		/// Transforms the 
+		/// </summary>
+		/// <typeparam name="T">Specifies the type of data that may be written to the channel.</typeparam>
+		/// <typeparam name="TResult">Specifies the type of data that may be read from the channel.</typeparam>
+		/// <param name="source">The source channel reader.</param>
+		/// <param name="transform">The transform function.</param>
+		/// <returns>A channel reader representing the tranformed results.</returns>
+		public static TransformChannel<T, TResult> Transform<T, TResult>(this Channel<T> source, Func<T, TResult> transform)
+			=> new TransformChannel<T, TResult>(source, transform);
 	}
 }

Open.ChannelExtensions/TransformChannel.cs

@@ -8,15 +8,16 @@ namespace Open.ChannelExtensions
 	/// A channel wrapper that takes the provided channel and transforms them on demand when being read.
 	/// </summary>
 	/// <typeparam name="TWrite">Specifies the type of data that may be written to the channel.</typeparam>
-	/// <typeparam name="TRead">Specifies the type of data that may be read from the channel.</typeparam>
-	public class TransformChannel<TWrite, TRead> : Channel<TWrite, TRead>
+	/// <typeparam name="TRead">Specifies the type of data read from the source channel.</typeparam>
+	/// <typeparam name="TResult">Specifies the type of data that may be read from the channel.</typeparam>
+	public class TransformChannel<TWrite, TRead, TResult> : Channel<TWrite, TResult>
 	{
 		/// <summary>
 		/// Creates a channel wrapper that takes the provided channel and transforms them on demand when being read.
 		/// </summary>
 		/// <param name="source">The channel containing the source data.</param>
 		/// <param name="transform">The transform function to be applied to the results when being read.</param>
-		public TransformChannel(Channel<TWrite, TWrite> source, Func<TWrite, TRead> transform)
+		public TransformChannel(Channel<TWrite, TRead> source, Func<TRead, TResult> transform)
 		{
 			if (source is null) throw new ArgumentNullException(nameof(source));
 			if (transform is null) throw new ArgumentNullException(nameof(transform));
@@ -26,4 +27,22 @@ public TransformChannel(Channel<TWrite, TWrite> source, Func<TWrite, TRead> tran
 			Reader = source.Reader.Transform(transform);
 		}
 	}
+
+	/// <summary>
+	/// A channel wrapper that takes the provided channel and transforms them on demand when being read.
+	/// </summary>
+	/// <typeparam name="T">Specifies the type of data that may be written to the channel.</typeparam>
+	/// <typeparam name="TResult">Specifies the type of data that may be read from the channel.</typeparam>
+	public class TransformChannel<T, TResult> : TransformChannel<T, T, TResult>
+	{
+		/// <summary>
+		/// Creates a channel wrapper that takes the provided channel and transforms them on demand when being read.
+		/// </summary>
+		/// <param name="source">The channel containing the source data.</param>
+		/// <param name="transform">The transform function to be applied to the results when being read.</param>
+		public TransformChannel(Channel<T, T> source, Func<T, TResult> transform)
+			:base(source, transform)
+		{
+		}
+	}
 }