问题标签 [node.js-stream]

我已经看过并阅读了一些教程，这些教程表明您可以将一个流传输到另一个几乎就像乐高积木一样，但是我找不到任何关于如何在将流通过管道传输到您的对象时捕获管道命令的任何内容。

我的意思是如何创建一个带有函数的对象，这样我就可以做到：

当数据通过管道传输到我的对象时，我该如何处理？

我看过，但我真的找不到任何关于这个的东西（也许我没有看过写的地方？）。

任何人都可以指出我正确的方向吗？

如果知道它有帮助，我想做的就是捕获一个数据流并构建一个包含二进制编码数据的字符串；无论是来自文件流还是来自服务器的请求流（即来自多部分请求的文件的数据）对象。

编辑：我已经更新了记录数据的代码

编辑：我已经修复它，我现在可以接收管道数据，我必须将代码放在一个包装器中，该包装器返回实现流的函数。

编辑：现在不同的问题，this.data不是_read以this.data上传功能可以读取的方式存储。

编辑：好的，现在我可以处理回调并捕获数据，我需要弄清楚如何判断数据是否正在通过管道传输给它，或者它是否被用作普通函数。

假设我创建了一个名为的转换流Parser，它可以像普通流一样写入，但可以作为对象流读取。我将readable事件用于使用此转换流的代码：

在这个事件处理程序中，我必须重复调用parser.read()吗？或者，是否会readable为从我的转换流中推送的每个对象自行触发？

我希望只有在传递给 _flush 的回调完成后才会触发“完成”回调，但它是在 _flush 完成之前触发的。为什么？

完成的node.js 流文档说只有当所有数据都被刷新到底层系统时才会触发事件。

查看 Node 的 Transform 流实现的源代码，它的意图似乎是仅在_flush调用回调时触发完成：

要么我错过了一些东西，要么这是 Node 的 Transform 流的错误。我认为是前者，但没有发现我的问题。谢谢你的帮助！

更新：请注意，如果我将调用替换为process.nextTick()同步调用sleep，如sleep模块提供的那样，那么问题就会消失。该问题仅由_flush.

我刚刚读到，如果流使用'data'或'end'侦听器，它会切换到“经典”模式，流手册说：

请注意，每当您注册“数据”侦听器时，都会将流置于兼容模式，因此您将失去新的 streams2 api 的好处

那么使用新流 api 的好处的最佳方法是什么？如果我目前正在这样做：

如何在不注册'end'监听器的情况下做同样的事情

我想使用 发送 HTTP post 请求scoped-http-client，如下所示：

我将如何传递节点流的数据？

如何在ar无人机v1.0上使用node js获取视频流或png流

我一直在看到 v2.0 的代码，甚至 gitHub 的人都说这些视频流库不适用于 v1。

有没有其他方法可以在计算机上获取 png / 视频流？

谢谢并恭祝安康

我有以下代码，它接受来自 url 的数据并打印 json 格式的数据。我想使用 node.js 将相同的数据发布到 mqtt。是否有相同的示例代码？

我正在阅读许多包含对象混合的文件。我有一个root流，可以流式传输对象，例如：

我将流通过管道root传输到 2 个单独的grep过滤流中，其中一个过滤action_type_a我们将调用A它，看起来像：

一个过滤action_type_b B看起来像：

我也有一个单独map的 id

所以对象上的 id 可以与对象A上的 id 匹配B

我想处理流A比较每个对象的 id 到地图，然后处理B看流中是否有相应的对象B

B在处理A.

我的第一个想法是B为A. 那可能吗？

我目前的尝试是在我试图读取和比较它的event-streams es.map流和映射函数内部使用我读过的我也写回记录到. 然而，这给了我：ABABB

(node) warning: possible EventEmitter memory leak detected. 11 listeners added. Use emitter.setMaxListeners() to increase limit.

错误，因为我B在地图中重新定义了侦听器A

我有一个名为server.js的文件，它读取一个名为“game.html”的 HTML 文件。

该 HTML 文件与名为“game.js”的外部 javascript 文件链接。

在 server.js 文件中

在 game.html 文件中

在 game.js 文件中

在 game.js 中使用“var fs = require('fs')”时，我总是遇到此错误。

ReferenceError：未定义要求

这个问题有什么解决办法吗？

我尝试创建聊天服务器，它将连接到 Android 客户端。1 客户端在服务器上发送一些数据，服务器接收它并发送给其余的客户端。所以我尝试使用'net'，但这不起作用。在服务器上，我正在监听 1490 端口和 192.168.3.XX 地址。现在我的客户可以连接到服务器，但发送数据不起作用。代码：