问题标签 [highland.js]

我试图让以下片段返回相同的输出 - 数组值流。

第一种方法从数组开始并发出值。

第二种方法将解析数组的 Promise 作为输入，因此它不会发出每个值，而是仅发出数组本身。

我应该在第二种方法中进行哪些更改以使其输出与第一种相同的内容？

我正在尝试使用 Highland.js 设计工作流程。我无法弄清楚 Highland.js 如何用于它。

我有一个基于流的工作流程如下（伪代码），

filterDuplicate 查找数据库以检查读取记录是否存在（使用条件）并返回布尔结果。为了使过滤器工作，它需要一个活动的数据库连接，我想在流完成之前重复使用它。一种方法是在读取之前打开连接并关闭写入的“完成”事件；这意味着我需要将连接作为参数传递以进行过滤和写入，如果两种方法都使用相同的数据库，这将起作用。

在上述工作流程中，filterDuplicate 和 write 也可能使用不同的数据库。所以我希望连接在每个函数中都包含和管理，这使它成为一个独立的可重用单元。

我正在寻找有关如何使用 Highland 进行设计的任何输入。

谢谢。

我是流的新手，我正在尝试使用 reactive-superglue/highland.js ( https://github.com/santillaner/reactive-superglue ) 从我的集合中获取数据。

我的卷曲请求：

目前，当我卷曲到我的端点时，我能够检索到响应，但只能检索一次。对我的服务器的任何其他请求都会触发stream error: Stream already being consumed, you must either fork() or observe().

我的堆栈：node、express、highlandjs、mongodb。

//我的端点函数

第二次尝试到达我的端点后的服务器响应： curl -i -X GET http://localhost:3000/queries/

我有一个从查询 mongo db 的快速 GET 请求中获得的 JSON 字符串。

res.write(string)给我：

但是，我只想呈现字符串中的某些信息，例如：epc、audit、ss.ts、v3.ts和v3.location。

我该怎么做呢？

我有一个使用 Highland 流的 node.js 应用程序。它使用数据源，并且需要将数据发送到多个目的地。问题是，通过读取数据并根据数据创建目标流来动态发现目标。

这意味着我不能通过.fork流添加目的地（因为已经开始消费的流不能被分叉，对吧？）

还有什么我可以做的吗？

我目前的方法是在.consume其中创建目标流并将数据写入目标。结果是丑陋和混乱的。

我正在尝试使用该splitby方法highland.js来提取开始和结束分隔符之间的数据。

我可以将文件读入这样的流：

但是，我似乎无法弄清楚如何处理文件并提取我需要的数据。

我遇到 highland.js 的问题。我需要从我的流数据中创建一个函数数组，但不能让它工作。这是我的代码，但requests总是空的。

我正在使用highland.js流来处理文件以读取两个分隔符之间的内容。我还async.js用来按顺序运行一系列 http 请求。

理想情况下，我想将xhighland 的输出作为第一个函数传递给async系列（链），以便为从流中提取的每个块执行 HTTP 请求。

这可能吗？如果是这样，如何实现？

给定node.js如下示例所示的样式对象流，如何通过http网页上的请求读取并处理它：