Linq.Take - Dmitry-Bychenko/Amphisbaena GitHub Wiki
Takes given number of items in ChannelReader.
public static ChannelReader<T> Take<T>(this ChannelReader<T> reader,
long count,
ChannelParallelOptions options)using Amphisbaena;
using Amphisbaena.Linq;
...
int[] data = new int[] {1, 2, 3, 4, 5, 6, 7, 8, 9};
int sum = await data
.ToChannelReader()
.Take(3)
.Aggregate((s, a) => s + a);