问题描述
我正在尝试创建一个文件读取器对象(来自 readFileSync)并提供来自生成器函数的行。我的目的是将这个 gnerator 对象传递给多个函数并按顺序解析一个文件。但是,在单一功能中使用发电机后,发电机的状态从暂停转变为关闭。我来自 Python 背景,这是 Python 中非常可能的操作。想知道我在这里做错了什么。以下是我使用的代码:
生成器函数定义(我使用的是 readFileSync 并且它不是异步的,请暂时忽略它,因为我正在尝试让生成器工作):
function* getFileGen(path: string){
const fileContent = fs
.readFileSync(path,{
encoding: "utf-8",flag: "r",})
.split("\n");
while(true){
const thisLine = fileContent.shift();
if(!thisLine){
break;
}
yield thisLine;
}
}
function getFirstFew(stream: Generator){
let i = 0;
for(let v of stream){
console.log(v);
if(i > 1){
break;
}
i++;
}
}
function getNextFew(stream: Generator){
let i = 0;
for(let v of stream){
console.log(v);
if(i > 7){
break;
}
i++;
}
const myStream = getFileGen('path/to/file');
getFirstFew(myStream);
getNextFew(myStream);
第一个函数正确执行,打印3行;但是当生成器传递给 getNextFew 函数时,它已经关闭了。
解决方法
来自docs:
在 for...of 循环中,突然的迭代终止可能由 break、throw 或 return 引起。在这些情况下,迭代器关闭。
而且,特别是:
不要重复使用生成器
不应重复使用生成器,即使 for...of 循环提前终止,例如通过 break 关键字。退出循环后,生成器将关闭,并尝试再次对其进行迭代不会产生任何进一步的结果。
强调我的。
不过我承认,我对 JS 不是很擅长,所以我不能推荐类似的解决方法。您可能需要使用列表或其他您有更多控制权的严格结构。
您可以实现一个类似于 Python 的 tee
的 tee
函数,该函数创建迭代器的副本,然后迭代其中一个副本。