ChannelUtils/Extensions.cs
/// <summary>
/// The last action on the channels data
/// </summary>
/// <param name="data"></param>
/// <param name="asyncAction"></param>
/// <param name="exceptionalChannel"></param>
/// <typeparam name="T"></typeparam>
/// <returns></returns>
The last action on the channels data
The last action on the channels data
public static Task[] Action<T>(
			this ChannelReader<T>[] data,
			Func<T, Task> asyncAction,
			ChannelWriter<DataProcessException>? exceptionalChannel = null)
		{
			return data.Select(x => x.Action(asyncAction, exceptionalChannel)).ToArray();
		}
public static Task [ ] Action < T > ( this ChannelReader < T > [ ] data , Func < T , Task > asyncAction , ChannelWriter < DataProcessException > ? exceptionalChannel = null ) { return data . Select ( x => x . Action ( asyncAction , exceptionalChannel ) ) . ToArray ( ) ; }
The last action on the channels data
The last action on the channels data
None
ChannelReader<T>[]
this
asyncAction
Func<T, Task>
None
exceptionalChannel
ChannelWriter<DataProcessException>?
None
data
None
typeparam
None