问题标签 [highland.js]

如何实现类似于combineLatest和 Highland 的行为？图书馆里好像没有类似的东西

我正在使用 Node.js 从 PostgreSQL 数据库中读取数据：

该query对象现在是一个事件发射器，row只要接收到一行就会发出事件。end此外，一旦读取了所有行，它就会发出一个事件。

我现在想做的是将此事件发射器包装到 Highland.js 流中，并将其交给我的函数的调用者。基本上这应该做的工作：

不幸的是，一旦读取了所有行，我仍然需要调用该disconnect函数，并且我不希望调用者关心这一点。那么如何在仍然能够为end事件注册回调的同时分发流呢？

我已经看到 Highland.js 提供了完全满足我需要的done函数，但它也导致流开始流动（我不想在内部做这件事，这取决于我的调用者）。

我该如何解决这个问题？

究竟是如何Highland.js实现背压的？我很好奇这个。

我有一组要并行使用的异步节点流，有没有一种简单的方法可以在高地 js 中做到这一点？我试图让所有这些数组都通过一个聚合函数。

我正在使用该highlandjs库来读取文件并在它们的内容中添加一个结束卡，然后再在控制台中显示它们：

我想highland.compose用来将这些包装成一个函数调用，我从以下开始：

我得到错误：

看起来组合函数没有返回 a highland stream。

使用异步函数消费高地流的正确模式是什么？似乎 .each 方法不适用于使用 wrapCallback 包装的节点样式异步函数。

我想做类似以下的事情。请注意，我还想捕获 .each 函数中生成的错误，并在所有异步消耗完成后触发 .done 函数。

谢谢你。

我正在尝试编写一个可写流，该流采用对象流并将它们输入到 mongodb 数据库中。在消费对象流之前，我首先需要等待数据库连接建立，但我似乎做错了什么，因为程序永远不会到达插入部分。

该程序只是退出而没有“建立连接！” 曾经被写入控制台。

我错过了什么？我应该遵循某种成语吗？

我知道observe()除非其他消费者已经在工作，否则不会消耗价值或触发消费，而fork()会自行触发消费。但是，假设我有一个 stream source_stream。如果我做

然后保证两个观察者收到相同的值。但如果我这样做

这两个分叉器会有什么价值？它们是相同的、不同的还是其他？什么规则决定了哪些值被推入其中？谢谢！

我想将任意但类似键控的对象流转换为 CSV 字符串流。为了做到这一点，我想查看流中的第一个对象，并为将添加到流中的对象键创建一个标题行。我已经做到了：

对于以下流

结果流应该是：

fork()但是，仅创建了标题行，因为我认为这是第一个流未完全消耗的背压问题。

那么，我怎样才能“窥视”流的第一个元素，然后根据该信息处理流呢？

我正在尝试从外部 API 获取 JSON 数组，然后同时发出该数组的一个元素。但是我的实现似乎在某个地方失败了，我收到错误而不是数组