ChannelUtils/Extensions.cs
/// <summary>
/// We transform the data in the channels and send it to a new
/// </summary>
/// <param name="data"></param>
/// <param name="asyncTransform"></param>
/// <param name="exceptionalChannel"></param>
/// <typeparam name="TInput"></typeparam>
/// <typeparam name="TOutput"></typeparam>
/// <returns></returns>
We transform the data in the channels and send it to a new
We transform the data in the channels and send it to a new
public static ChannelReader<TOutput>[] Transform<TInput, TOutput>(
			this ChannelReader<TInput>[] data,
			Func<TInput, Task<TOutput>> asyncTransform,
			ChannelWriter<DataProcessException>? exceptionalChannel = null)
		{
			return data.Select(x => x.Transform(asyncTransform, exceptionalChannel)).ToArray();
		}
public static ChannelReader < TOutput > [ ] Transform < TInput , TOutput > ( this ChannelReader < TInput > [ ] data , Func < TInput , Task < TOutput > > asyncTransform , ChannelWriter < DataProcessException > ? exceptionalChannel = null ) { return data . Select ( x => x . Transform ( asyncTransform , exceptionalChannel ) ) . ToArray ( ) ; }
We transform the data in the channels and send it to a new
We transform the data in the channels and send it to a new
None
ChannelReader<TInput>[]
this
asyncTransform
Func<TInput, Task<TOutput>>
None
exceptionalChannel
ChannelWriter<DataProcessException>?
None
data
None
typeparam
None
typeparam
None