c# - Rx 按标准和标准后的 n 个值过滤

Question

仅按条件过滤

changes.Where(p => Evaluate(p)).Subscribe(p => { // Do something });

但是你如何才能得到标准值和满足标准后的 n 个值(并且这 n 个值不必与评估标准匹配)？

• 例如我想订阅一个返回 Evaluate(p) 和之后的一个值的流(然后再次开始评估 p)

Answer 1

请看SkipWhile和 Take IEnumerable 的扩展方法.您可以尝试以下代码:

changes.SkipWhile(change => Evaluate(change) == false).Take(n).Subscribe(change => { /* do something */ });

编辑

新代码从尾部为 n 项的序列中获取所有匹配项(无需重复检索项)

// Let's assume elements in the sequence are of type Change
int i = 0;
Func<Change, bool> evaluateWithTail = change =>
{
    if (i <= 0 || i > n)
    {
        i = Evaluate(change) ? 1 : 0;
    }
    else
    {
        i++;
    }

    return i > 0;
}
// Please note delegate is specified as parameter directly - without lambda expression
changes.Where(evaluateWithTail).Subscribe(change => { /* do something */ });