ChannelUtils/Extensions.cs
/// <summary>
/// We process the data in the channels and send it into new
/// </summary>
/// <param name="data"></param>
/// <param name="action"></param>
/// <param name="exceptionalChannel"></param>
/// <typeparam name="T"></typeparam>
/// <returns></returns>
We process the data in the channels and send it into new
We process the data in the channels and send it into new
public static ChannelReader<T>[] Process<T>(
			this ChannelReader<T>[] data,
			Action<T> action,
			ChannelWriter<DataProcessException>? exceptionalChannel = null)
		{
			return data.Select(x => x.Process(action, exceptionalChannel)).ToArray();
		}
public static ChannelReader < T > [ ] Process < T > ( this ChannelReader < T > [ ] data , Action < T > action , ChannelWriter < DataProcessException > ? exceptionalChannel = null ) { return data . Select ( x => x . Process ( action , exceptionalChannel ) ) . ToArray ( ) ; }
We process the data in the channels and send it into new
We process the data in the channels and send it into new
None
ChannelReader<T>[]
this
action
Action<T>
None
exceptionalChannel
ChannelWriter<DataProcessException>?
None
data
None
typeparam
None