如何解决如何使用Node.js中的管道将数据流从一个流移动到另一流
下面是NodeJS中的示例程序,该程序从数据文件中提取数据,并确保每个缓冲区在该数据文件中都是一行,并最终打印出每一行。
问题。
引擎盖下到底发生了什么魔术,一次拾取一个缓冲区并将其传递给另一个流?换句话说,pipe()
和next()
函数的作用是什么?我们可以自己实现这些功能吗?如果可能的话,请有人给我举个例子。我知道如果我知道这些功能的实现是没有用的,但是我很好奇知道所使用的底层JavaScript魔术。
var through = require('through2');
var split = require('split2');
var fs = require('fs');
const { connected } = require('process');
fs.createReadStream('./data-file.txt')
.pipe(split())
.pipe(through(readFromText));
function readFromText(buf,enc,next){
console.log(buf.toString());
next();
};
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。