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

mtb9vblg  于 2023-02-18  发布在  Node.js
关注(0)|答案(3)|浏览(116)

我正在使用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个终端上登录,并在下面的createReadStream调用中使用未运行节点的终端的pty。

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。

uurv41yg

uurv41yg1#

而不是使用

readStream.close(),

尝试使用

readStream.pause().

但是,如果您使用的是最新版本的node,请使用由isaacs从stream模块创建的对象 Package readstream,如下所示:

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

然后使用myReader代替readStream。
祝你好运!告诉我这个管用不。

tp5buhyn

tp5buhyn2#

您正在关闭/dev/random流,但直通上仍有'data'事件的侦听器,该侦听器将保持应用运行,直到直通关闭。
我猜读数据流中有一些缓冲数据,在这些数据被刷新之前,传递函数不会关闭,但这只是一个猜测。
要获得所需的行为,您可以删除直通上的事件侦听器,如下所示:

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

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

zrfyljdw3#

我实际上是通过管道发送到http请求。因此,对我来说,它是:

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

相关问题