问题标签 [highland.js]

我想处理长度约为 100 000 的数组，而不会给 CPU 带来太多负载。我研究了流并偶然发现了 highlandjs，但我无法使其工作。

我也尝试过使用承诺和分块处理，但它仍然给 CPU 带来了很大的负载，如果需要，程序可能会很慢，但不应该给 CPU 带来负载

我有以下功能：

流参数是自动注入的，我 100% 确定流注入有效（其他流函数有效）。

当我用简单的东西替换这个有点复杂的转换时_(numbers).each(xs => {console.log(xs)})，我可以看到正在记录的数据。

但是，在这里，我必须清楚地错过Highland.js的某些内容，因为根本没有产生任何东西。

我正在使用 Highland.js 的 2.13.5 版本。

我错过了什么？

我正在编写一个小脚本来流式下载并处理来自 url 的一些按顺序命名的文件。我正在使用 highlandjs 并让它一一完美地工作。我正在尝试重构为一个循环，在该循环中我等待一个高地流的完成，然后再开始另一个：

我应该如何包装我的 processFile 函数，以便在继续下一次迭代之前等待它完成？

当使用 highlandjs 创建流时，我知道我可以像这样使用它：

现在我想将流分成两个，对它们都做一些事情，然后将两个两个叉合并成一个流。（或者换一种说法：我想将流分成两部分，但它们的操作结果应该是相同的响应流。）

然而我无法让它发挥作用。该示例非常做作，但展示了我的问题：

然后结果流被暂停。我认为只有在所有叉子开始处理输入流之后才开始使用叉子，但我不确定如何启动它。

假设我有两个高地溪流：

我想映射accounts流并合并额外的数据，accountData因此结果如下所示：

这对于普通数组来说非常简单，但我想知道在使用流时是否可能。

我正在尝试聚合时间序列数据的数据流。减少工作，但是我找不到将结果数组返回到另一个流的解决方案。

当我在 reduce 上调用 map 时，我只会返回整个数组作为结果。不是数组中的数据。

欢迎任何想法或提示。