如何从 IObservable <T>中选择值的递增子序列

Question

这个方法怎么写?

public static IObservable<T> IncreasingSubsequence<T>(this IObservable<T> observable, IComparer<T> comparer)
{
    // ???
}

生成的可观察对象应该只推送那些超过先前所有值最大值的值。

Answer 1

另一种方法是使用Scan和DistinctUnitChanged。下面是一个使用int的简单示例

IObservable<int> xs;
xs.Scan((last,cur) => cur > last ? cur : last).DistinctUntilChanged()

和更一般的形式

public static IObservable<T> IncreasingSubsequence<T>(this IObservable<T> xs, IComparer<T> comp)
{
    return xs.Scan((last,cur) => comp.Compare(cur, last) == 1 ? cur : last)
                     .DistinctUntilChanged();
}

Answer 2

我认为最简单的方法是使用Where()和闭包是可变的事实:

public static IObservable<T> IncreasingSubsequence<T>(
    this IObservable<T> observable, IComparer<T> comparer = null)
{
    if (observable == null)
        throw new ArgumentNullException("observable");
    if (comparer == null)
        comparer = Comparer<T>.Default;
    T max = default(T);
    bool first = true;
    return observable.Where(x =>
    {
        if (first)
        {
            first = false;
            max = x;
            return true;
        }
        if (comparer.Compare(x, max) > 0)
        {
            max = x;
            return true;
        }
        return false;
    });
}