我正在使用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。
3条答案
按热度按时间uurv41yg1#
而不是使用
尝试使用
但是,如果您使用的是最新版本的node,请使用由isaacs从stream模块创建的对象 Package readstream,如下所示:
然后使用myReader代替readStream。
祝你好运!告诉我这个管用不。
tp5buhyn2#
您正在关闭
/dev/random
流,但直通上仍有'data'
事件的侦听器,该侦听器将保持应用运行,直到直通关闭。我猜读数据流中有一些缓冲数据,在这些数据被刷新之前,传递函数不会关闭,但这只是一个猜测。
要获得所需的行为,您可以删除直通上的事件侦听器,如下所示:
zrfyljdw3#
我实际上是通过管道发送到http请求。因此,对我来说,它是: