async for 循环导致函数静默终止

Question

您好，我试图了解以下代码中发生的情况：import fs from "fs";import util from "util";import split2 from "split2";async function main() {    const files = await fs.promises.readdir("..");    for (const f of files) {        const s = fs.createReadStream("../" + f);        const ss = s.pipe(split2());        s.on("error", (err) => {            console.log(err);        });        for await (const l of ss) {        }        console.log(f);    }    console.log("Returning");    return "Done";}main();它基本上读取目录中的每个文件并迭代每个文件的行（通过使用 forawait 语法将可读流通过管道输送到 split2 库中。问题是，当文件确实是目录时，createReadStream 失败（随后什么也没有发生）奇怪的是，似乎一个错误导致主函数默默退出并在错误之前仅显示几个文件名。.gitignoreapp.js[Error: EISDIR: illegal operation on a directory, read] {  errno: -21,  code: 'EISDIR',  syscall: 'read'}如果我只是评论await for 循环，我会得到以下输出。.gitignoreapp.jsbusinesscomponentsconfigenv.skeletronnode_modulespackage-lock.jsonReturning[Error: EISDIR: illegal operation on a directory, read] {  errno: -21,  code: 'EISDIR',  syscall: 'read'}[Error: EISDIR: illegal operation on a directory, read] {  errno: -21,  code: 'EISDIR',  syscall: 'read'}[Error: EISDIR: illegal operation on a directory, read] {  errno: -21,  code: 'EISDIR',  syscall: 'read'}[Error: EISDIR: illegal operation on a directory, read] {  errno: -21,  code: 'EISDIR',  syscall: 'read'}[Error: EISDIR: illegal operation on a directory, read] {  errno: -21,  code: 'EISDIR',  syscall: 'read'}[Error: EISDIR: illegal operation on a directory, read] {  errno: -21,  code: 'EISDIR',  syscall: 'read'}[Error: EISDIR: illegal operation on a directory, read] {  errno: -21,  code: 'EISDIR',  syscall: 'read'}[Error: EISDIR: illegal operation on a directory, read] {  errno: -21,  code: 'EISDIR',  syscall: 'read'}  这确实是完整的文件列表，并且各个错误不会停止外循环。我在 Ubuntu 机器上使用节点 v14.0.0 运行它。知道发生了什么事吗？我真的迷路了:-D

Answer 1

您没有处理循环中的错误for await (const l of ss) {...}。当您尝试在目录上运行它时，您的for await循环将拒绝，并且由于您没有捕获或处理该拒绝，因此包含的async函数也将拒绝并且程序将停止。

您可以尝试在循环中放置 try/catchfor await并查看是否有效。但是，我在流功能中发现了许多错误for await，甚至提交了一些错误。如果打开文件时出错或读取文件时出错，则会出现错误，因此此功能只是有错误，因此我决定不在我的代码中使用它。

另请注意，您没有一个好的方法来从事件中传达错误，error因为您无法拒绝async嵌套事件处理程序内部的函数。总体而言，流及其事件与基于承诺的编程不能很好地融合。有多种方法可以承诺某些流事件，但要使流与承诺良好配合，还需要进行中。