为什么此readline异步迭代器无法正常工作？

这是一个更大的过程的一部分，我将其简化为节点v14.4.0中的最小，可重复的示例。在这段代码中，它从for循环内部什么都不输出。

我在控制台中仅看到以下输出：

before for() loop
finished
finally
done

该for await (const line1 of rl1)循环永远不会进入for循环-它只是跳过就在它：

const fs = require('fs');
const readline = require('readline');
const { once } = require('events');

async function test(file1, file2) {
    try {
        const stream1 = fs.createReadStream(file1);
        await once(stream1, 'open');
        const rl1 = readline.createInterface({input: stream1, crlfDelay: Infinity});

        const stream2 = fs.createReadStream(file2);
        await once(stream2, 'open');
        const rl2 = readline.createInterface({input: stream2, crlfDelay: Infinity});

        console.log('before for() loop');
        for await (const line1 of rl1) {
            console.log(line1);
        }
        console.log('finished');
    } finally {
        console.log('finally');
    }
}

test("data/numbers.txt", "data/letters.txt").then(() => {
    console.log(`done`);
}).catch(err => {
    console.log('Got rejected promise:', err);
})

但是，如果删除其中任何一条await once(stream, 'open')语句，则for循环将完全执行预期的操作（列出rl1文件的所有行）。因此，显然，在与流之间的readline接口中，异步迭代器存在一些计时问题。任何想法可能会发生什么。任何想法可能导致此问题或如何解决吗？

仅供参考，await once(stream, 'open')是因为异步迭代器中的另一个错误，该错误在打开文件时不会拒绝，而在无法打开文件的情况下await once(stream, 'open')会导致您正确拒绝（实质上是对打开文件进行预检查） 。

如果您想知道为什么存在stream2代码，它将在较大的项目中使用，但是我已将此示例简化为最小的，可重现的示例，并且只需要大量的代码即可演示该问题。

编辑：在尝试一个稍有不同的实现时，我发现如果将两个once(stream, "open")调用合并到一个中Promise.all()，则它将起作用。因此，这可行：

const fs = require('fs');
const readline = require('readline');
const { once } = require('events');


async function test(file1, file2) {
    try {
        const stream1 = fs.createReadStream(file1);
        const rl1 = readline.createInterface({input: stream1, crlfDelay: Infinity});
        const stream2 = fs.createReadStream(file2);
        const rl2 = readline.createInterface({input: stream2, crlfDelay: Infinity});
        // pre-flight file open to catch any open errors here
        // because of existing bug in async iterator with file open errors
        await Promise.all([once(stream1, "open"), once(stream2, "open")]);

        console.log('before for() loop');
        for await (const line1 of rl1) {
            console.log(line1);
        }
        console.log('finished');
    } finally {
        console.log('finally');
    }
}

test("data/numbers.txt", "data/letters.txt").then(() => {
    console.log(`done`);
}).catch(err => {
    console.log('Got rejected promise:', err);
});

显然，这不应该确切地对您等待文件打开的方式敏感。某处存在一些计时错误。我想在readline或readStream上找到该错误并将其归档。有任何想法吗？