问题标签 [highland.js]

我正在尝试将Highland.js用于一组Mongoose模型上的数据库更新脚本，它似乎非常适合在Model.find(). 我有一些同步的事情要做（更新我的模型以符合新模式，一些清理操作），最后我想要save()文档。我配置了一些需要运行的预保存挂钩，并且更新与直接的Model.update(). 我已经设法通过Q.js和 Highland 的组合来实现它：

然而，这似乎并没有解决这个承诺，我不确定这是否是让事情保持良好和流畅的“正确”方式......将 Q.js 和 Highland.js 结合起来似乎也很奇怪，所以亲密地。有没有更好的办法？

我有来自readdirp模块的目录流。

我想要：-

• README.*在每个目录中使用正则表达式（例如）搜索文件
• 读取该文件的第一行不以#
• 打印出每个目录和目录中 README 的第一个非标题行。

我正在尝试使用流和highland.js来做到这一点。

我被困在试图处理每个目录中所有文件的流。

我正在尝试使用流响应的请求库。以下代码按预期工作。

然而，当我尝试对 highland.js 做同样的事情时，事件处理程序永远不会被触发。

我在这里缺少什么超级琐碎的东西吗？

我喜欢 Highland.js 和一般的反应式编程风格。我正在为上下文的丢失而苦苦挣扎，我正在尝试确定如何在目标是放弃状态的模型中优雅地处理上下文。

例如，我在 Amazon Web Services 中有一组帐户。

我的目标是创建一个包含我在一个区域中运行的所有 EC2 实例的电子表格。像这样的东西。

一般的工作流程是

1. 浏览每个帐户
2. 调用 ec2DescribeInstaces
3. 以某种方式将每个 ec2DescribeInstances 回调映射到最终输出的帐户名称

在普通的 JavaScript 中，我们会在这里循环，所以当我们每次调用 ec2DescribeInstances 时，都会存在一个上下文

根据我对反应式编程的理解，我会做这样的事情

有指导吗？？？所以在这条链的末端，我有来自亚马逊的实例。但我不确定如何将这些与帐户联系起来以获取名称。我知道我可以绕过这个来获得价值，但我正在寻找最佳实践和优雅的东西。

所以@Bergi，就像下面一样？？？这将返回一个“上下文”对象，其中包含我需要的数据以及从亚马逊返回的数据。我对此唯一担心的是，如果我在整个链中传递上下文，那么我们将为调用进行大量数据提取、填充和包装。

我正在尝试编写一种非常实用的方式。我们使用 Highland.js 来管理流处理，但是因为我是新手，我想我对如何处理这种独特的情况感到非常困惑。

这里的问题是文件流中的所有数据都不一致。文件中的第一行通常是标题，我们希望将其存储到内存中，然后压缩流中的所有行。

这是我的第一次尝试：

管道中的第一个命令是按行拆分文件。接下来抓取标题，doto 将其声明为全局变量。问题是流中的下几行不存在，因此进程被阻止......可能是因为它上面的 head() 命令。

我尝试了其他一些变体，但我觉得这个例子让你知道我需要去哪里。

对此的任何指导都会有所帮助——它还提出了一个问题，即如果我在每一行中都有不同的值，我如何才能在许多可变长度/复杂度的不同流操作中分裂流程流。

谢谢。

编辑：我产生了更好的结果，但我质疑它的效率——有没有办法可以优化它，所以每次运行时我都不检查是否记录了标题？这感觉还是很草率的。

我有一个场景，我的生产者运行得比我的消费者快得多，有很多数据。但是，我不想阻止生产者。所以唯一的选择是通过文件缓冲额外的数据。

我设法提出了一个非最佳解决方案。但是，必须有一种更务实的方式来实现这一点。

我更熟悉 RxJS，我可能不会有太多问题，但我刚刚开始切换到高地，希望得到一些建议。

我有一个定期从服务器获取数据的 Highland 流。我需要在地图内进行数据库查找。我找不到任何提到在任何 Highland 的变形金刚中做任何异步的事情。

我写了一个简单的脚本，应该算行

但由于某些原因，我在控制台中什么也看不到。文档中提到了惰性，但each调用应该“调用”流。如何解决问题？

注意：这是关于 highland.js 的问题，而不是关于计算行数的方法

考虑一个问题：

• 按行拆分文件
• 将行写入结果文件
• 如果结果文件超过某个大小，则创建一个新的结果文件

例如，如果我有一个重量为 4gb 且拆分大小等于 1gb 的文件。结果是四个文件的重量为 1gb。

我正在寻找具有 Rx*/Bacon 或任何其他类似库的任何语言的解决方案。

在Node.js可写流中，我们可以检测缓冲并暂时停止写入流，直到drain事件发生。

有什么方法可以得知该Highland流已恢复，以便我们可以继续写入它而无需缓冲？