ReactiveX：从 observable 中过滤掉数字，使总数永远不会低于零答案

【问题标题】：ReactiveX: filter out numbers from observable so that total never goes below zeroReactiveX：从 observable 中过滤掉数字，使总数永远不会低于零
【发布时间】：2018-08-16 08:46:41
【问题描述】：

以下 RxJs 代码显示输入列表中的数字和运行总数：

let inputs = [10, 10, -30, 10, -30, 50, -25, -30, 10]

let obs$ = Rx.Observable.from(inputs)
let totals$ = obs$.scan((acc, next) => acc + next, 0)
obs$.subscribe(x => console.log('x:', x));
totals$.subscribe(x => console.log("total:", x))

totals$ 将发出：10、20、-10、0、-30...

我想以某种方式转换 obs$ 可观察对象，以便生成的 totals$ 永远不会发出负数。

即，在这种情况下，第一个和最后一个“-30”都应该被过滤掉：

otherObs$: 10, 10, 10, -30, 50, -25, 10

totals$: 10, 20, 30, 0, 50, 25, 35

编辑：请注意，我对修改后的otherObs$ 可观察对象感兴趣，即过滤掉一些原始输入数字的序列（obs$ 实际上会包含更多数据，所以我确实需要原始元素; “价值”只是过滤的关键）。 totals$ 此处仅用于显示正在发生的事情。

【问题讨论】：

标签： javascript rxjs reactive-programming reactivex

【解决方案1】：

您可以通过将该逻辑合并到您的 reduce 函数中轻松实现这一点，也就是在 .scan() 中：

let total$ = obs$.scan((acc, next) => {
    if (acc + next < 0) { //less than zero, don't take in the current number
        return acc;
    }
    return acc + next; //all is good, continue to add next
}, 0)

甚至在一个班轮中：

let totals$ = obs$.scan((acc, next) => (acc + next < 0 ? acc : acc + next), 0)

如果你想保留每个值并且仍然检查总和，那么别无选择，只能将每个序列存储在数组中：

let other$ =
    obs$
        .scan((acc, next) => {
            let sum = acc.reduce((a,b)=>a+b);
            if((sum+next)<0){
                return acc; // less than zero, return current arrray
            }
            return  acc.push(next); //greater or equal to zero, add current item to array
        }, [...0])
        .switchMap(array => Observable.from(array))

【讨论】：

不幸的是，我对原始序列中的数字感兴趣，而不是总数。我想得到一个可观察的，这样当我应用我原来的 totals$ reduce 时，我得到了非负数

【解决方案2】：

根据@CozyAzure 的想法，我想出了一个更好的答案。我只需要在 reducer 中存储更多状态：原始值、累计总数以及该值是否添加到总数中。

let other$ = obs$
  .scan(({value, total, valid}, next) => {
     if (total + next < 0)
       return { value: next, total: total, valid: false }
     else
       return { value: next, total: total + next, valid: true }
  }, { value: undefined, total: 0, valid: false })
  .filter(x => x.valid)
  .map(x => x.value)

这样，我可以过滤掉没有添加的值，并取回原来的值。

【讨论】：