MessagePipe_blog06.cs

// don't send same value(Rx's DistinctUntilChanged) by Filter
public class ChangedValueFilter<T> : MessageHandlerFilter<T>
{
    T lastValue;
​
    public override void Handle(T message, Action<T> next)
    {
        if (EqualityComparer<T>.Default.Equals(message, lastValue))
        {
            return;
        }
​
        lastValue = message;
        next(message);
    }
}