javascript - 如何使用 rxjs 的 sum 运算符？

Question

我尝试过的事情包括以下 where values 是我想要找到总和的值的数组。
我还从 rxjs 添加了必要的功能，如下所示:
我收到一条错误消息

typeError: Rx.Observable.from(...).sum is not a function

const { merge , interval ,from} = rxjs;
const { tap ,take ,sum } = rxjs.operators;   
             
var sumSource = Rx.Observable.from(values).sum(function (x) {
    return x;
});

var subscription = sumSource.subscribe(
    function (x) {
        console.log('Next: ' + x);
        x.target.value = x;
    },
    function (err) {
        console.log('Error: ' + err);
    },
    function () {
        console.log('Completed');
    }
);

互联网上关于 sum 的信息不多。有任何输入来修复和获取总和吗？

Answer 1

总和:关于官方 rxjs github repository他们不导出/提供sum运营商了。

减少运算符 reduce对源 Observable 应用累加器函数，并在源完成时返回累加结果。

扫描运算符 scan对源 Observable 应用一个累加器函数，并在每次发射时返回累加结果。

设置

const values = [1,2,3,4,5];
const accumulator = (acc, curr) => acc + curr;

实现减少

from(values).pipe(
  reduce(accumulator, 0)
)
// Expected output: 15

实现扫描

from(values).pipe(
  scan(accumulator, 0)
)
// expected output: 1, 3, 6, 10, 15

我做了一个正在运行的 stackblitz here .