问题标签 [node.js-stream]

我有一个通过侦听data、error和end事件来处理的流，我调用一个函数来处理data第一个流中的每个事件。自然，处理数据的函数调用其他回调，使其异步。那么在处理流中的数据时如何开始执行更多代码呢？监听end流中的事件并不意味着异步data处理功能已经完成。

如何确保在执行下一条语句时完成流数据处理功能？

这是一个例子：

如何确保callThisOnlyAfterAllAccountsAreMigrated在处理流之后调用它？

这可以通过承诺来完成吗？可以通过流来完成吗？我正在使用 Nodejs，因此引用其他 npm 模块可能会有所帮助。

我的以下代码在运行 node.js 0.12.0 的本地主机上运行良好。该代码创建一个新文件，并从可读文件中复制数据，但它不会在 Heroku 上创建新文件。

我认为这与权限有关，但每当我更改文件夹的权限时，heroku run bashHerokuchmod -R 777 images/都会将其重置为原始权限，即drwx------.

那么问题可能是别的吗？

请注意，它静默失败，没有例外，日志中没有任何内容。

我基本上想做这样的事情：

请注意，这less只是一个示例。我需要它与任何其他 *nix 命令一起使用。

关于用例的更多信息：
我编写了一个节点 CLI 包，用于搜索一些在线资源并将结果输出到 shell。由于结果集可能很大，客户想要对其进行额外的操作，例如grep, head, tail, tee, ... 任何东西。

我进行了广泛的搜索，我只设法找到了进入节点程序的方法，而不是从. 我目前的想法是在调用我的程序时捕获管道的右侧，然后，在我获得结果后，使用child_process.exec. 不确定这是否可行？

请注意，每次调用我的程序时，它都是一个新进程，即程序没有自己的提示符。

谢谢

类似于“现在无法切换到旧模式”- tls.connect 函数中的 Node.JS apn 模块错误我在暂停可读流时抛出“现在无法切换到旧模式”错误（在这种情况下是 HTTP 响应/传入消息）

IncomingMessage 在正文中有 XML，我将其输入到sax-js处理程序中。然后，处理程序将输出写入通过管道传输到某个目的地的PassThrough流。阅读文档，我不确定我做错了什么readable.pause()。readable.resume()是否有一些关于流动流的东西我错过了，或者我在下面实现了错误的模式？

更新以更好地解释问题：我正在尝试构建一个简单的代理服务器模块，该模块将允许实现者监听和修改来自源服务器的响应。当代理收到响应时，我会发出customResponse一条引用响应流的消息。任何监听该事件的人都应该能够通过管道获取响应并实现自定义业务逻辑。该模块应该负责返回客户端的“最终”管道 - 否则它将不是代理（参见下面的示例代码）。

1. 安装

   /li>

2. index.js

   /li>

我对Busboy模块有点困惑。我不明白它将文件数据流到哪里，因为它只接受请求标头作为参数？！看一下文档中的示例：

这是我尝试做
的目标：删除声明和 doctype 标记的 XML 文档管道流。
问题
第 1 部分。解决此问题的最佳方法是什么。我应该使用 FS 模块的 createReadStream 和 createWriteStream 方法吗？
第 2 部分。如何从一个流中删除文本并将其通过管道传输到另一个流中？

I have been trying to use a readable and a transform stream to process a very large file. The problem that I seem to come across is that if I don't put a writable stream at the end, the program seems to terminate before the result gets returned.

Example : rstream.pipe(split()).pipe(tstream)

My tstream has an emitter that emits when a counter hits a threshold. When that threshold is set to a low number, I get a result, but when it's high, it's not returning anything. If I pipe it to a file writer, it always returns a result. Am I missing something obvious?

code:

Here is the code for the Qtransformstream

我正在尝试提取 .tar 文件（从目录中打包），然后检查提取目录中文件的名称。我正在使用tar-fs来提取 tar 文件，然后使用 fs.createReadStream 来操作数据。这是我到目前为止所得到的：

我希望提取整个文件夹，然后检查文件名。嗯，我还没到那一步。。

据我了解，管道后我得到了一个可读的流。一个可读流有一个结束事件？我的问题是，为什么end不调用代码中的事件？

谢谢！

这就是它应该在 Node.Js 上做的事情

我被困在 6:16，它说“node server.js”应该打开 127.0.0.1:3000，但我得到的只是这个错误。

在我的浏览器上显示“ERR_CONNECTION_REFUSED”

XAMMP 没有任何问题，我真的不需要打开端口 80 来进行 beta 测试。