ForAll

Perform action for all items within ChannelReader

Declaration (has overloads)

public static async Task ForAll<T>(this ChannelReader<T> reader,
                                        Action<T> action,
                                        ChannelParallelOptions options)

Example

using Amphisbaena;
using Amphisbaena.Linq;

...

int[] data = new int[] {1, 2, 4, 5, 9};

await data
  .ForAll(item => Console.WriteLine($"{item}"));