如何关闭没有更多数据要发送到 node.js 的流

Question

我正在使用node.js并通过打开/dev/tty文件从串行端口读取输入，我发送命令并读取命令的结果，一旦我读取并解析了所有数据，我想关闭流。我知道我已经完成了数据标记的读取。 我发现一旦我关闭了流，我的程序就不会终止。

下面是我所看到的示例，但使用/dev/random 来缓慢生成数据（假设您的系统没有做太多事情）。 我发现，一旦设备在流关闭后生成数据，该过程就会终止。

var util = require('util'),
    PassThrough = require('stream').PassThrough,
    fs = require('fs');
// If the system is not doing enough to fill the entropy pool
// /dev/random will not return much data.  Feed the entropy pool with :
//  ssh <host> 'cat /dev/urandom' > /dev/urandom
var readStream = fs.createReadStream('/dev/random');
var pt = new PassThrough();
pt.on('data', function (data) {
    console.log(data)
    console.log('closing');
    readStream.close();  //expect the process to terminate immediately
});
readStream.pipe(pt);

更新日期：1

我回到了这个问题并有另一个示例，这个示例仅使用 pty，并且很容易在节点 repl 中重现。 在 2 个终端上登录，并在下面的调用中使用您未运行的终端节点的 pty 来创建 ReadStream。

var fs = require('fs');
var rs = fs.createReadStream('/dev/pts/1'); // a pty that is allocated in another terminal by my user
//wait just a second, don't copy and paste everything at once
process.exit(0);

此时节点将只是挂起而不退出。 这是在 10.28。

Answer 1

而不是使用

readStream.close(), 

尝试使用

readStream.pause().

但是，如果您使用的是最新版本的节点，请使用 isaacs 从流模块创建的对象包装阅读流，如下所示：

var Readable = require('stream').Readable;
var myReader = new Readable().wrap(readStream);

之后使用 myReader 代替 readStream。

祝你好运！告诉我这是否有效。

Answer 2

你正在关闭/dev/random流，但你仍然有一个侦听器来检测传递上的'data'事件，这将使应用保持运行，直到传递关闭。

我猜读取流中有一些缓冲数据，在刷新之前，直通不会关闭。但这只是一个猜测。

要获得所需的行为，您可以像这样删除直通时的事件侦听器：

pt.on('data', function (data) {
  console.log(data)
  console.log('closing');
  pt.removeAllListeners('data');
  readStream.close();
});

Answer 3

我实际上是通过管道连接到HTTP请求..所以对我来说它是关于：

pt.on('close', (chunk) => {
  req.abort();
});