Distinct

Remove duplicate items from ChannelReader.

Declaration (has overloads)

public static ChannelReader<T> Distinct<T>(this ChannelReader<T> reader,
                                                IEqualityComparer<T> comparer,
                                                ChannelParallelOptions options)

Example

using Amphisbaena;
using Amphisbaena.Linq;

...

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

bool result = await data
   .ToChannelReader()
   .Distinct()
   .SequenceEquals(new int[] { 1, 2, 3, 4 });