node.js - nodejs：计算高地流的平均值

Question

我刚刚开始使用 highland.js 和 node 中的流，我一直试图计算一些数字的最小/最大/平均值。这是我到目前为止所拥有的：

const _ = require('highland');

const input = [
 { val: 1 },
 { val: 2 },
 { val: 3 },
];

_(input)
  .reduce((acc, { val }) => {
    if (typeof acc.min === 'undefined' || val < acc.min) {
      acc.min = val;
    }
    if (typeof acc.max === 'undefined' || val > acc.max) {
      acc.max = val;
    }
    acc.count = (acc.count || 0) + 1;
    acc.sum = (acc.sum || 0) + val;
    return acc;
  }, {});

如果我这样做，比如说，toCallback我console.log得到的结果， {min: 1, max: 3, count: 3, sum: 6}但我对 count 和 sum 字段不感兴趣，我想要像{min: 1, max: 3, mean: 2}.

但是，由于reduce的返回是一个对象，所以highland不能用它做任何事情——我只能消耗它，但我想在highland做平均。

我该如何从这里继续，或者我应该如何重构代码以获得平均值？

Answer 1

您可以尝试像这样使用 highland .map 方法：

_(input)
	.reduce({}, (acc, {val}) => {
		if (typeof acc.min === 'undefined' || val < acc.min) {
			acc.min = val;
		}
		if (typeof acc.max === 'undefined' || val > acc.max) {
			acc.max = val;
		}
		acc.count = (acc.count || 0) + 1;
		acc.sum = (acc.sum || 0) + val;
		return acc;
	})
	.map(stats => {
		return {
			min: stats.min,
			max: stats.max,
			mean: stats.sum / stats.count
		};
	})
	.toCallback(function (err, data) {
		//Contains the data structure you need
		console.log(data);
	});