如何关闭在 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 来调用 createReadStream。

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

您正在关闭/dev/random 流，但您仍有一个侦听器，用于侦听传递中的'data' 事件，这将使应用程序保持运行直到传递关闭。

我猜有一些来自读取流的缓冲数据，在刷新之前，传递不会关闭。但这只是猜测。

要获得所需的行为，您可以像这样删除传递中的事件侦听器：

pt.on('data', function (data) {
  console.log(data)
  console.log('closing');

  pt.removeAllListeners('data');
  readStream.close();
});

Answer 2

而不是使用

readStream.close(), 

尝试使用

readStream.pause().

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

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

然后使用 myReader 代替 readStream。

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