Node Promise 不值得等待

Question

所以尽我所能了解 node.js 中的流、promise 和异步函数。我似乎从来没有做对。我有几个非常相似的用例（而且看起来很标准）。像这样的：

1. 我有一个获取一些数据的流
2. 我需要将其通过管道传输到进程（在本例中为 fast-csv）
3. 完成后，我需要将其发送到下一步（在实际情况下，发送到数据库）
4. 在真实场景中，我需要等待数据库更新完成
5. 下一个打开下一个文件流
6. 处理
7. 添加
8. 重复...

所以下面的代码“应该”做到这一点，但承诺不会等待解决。 Await 仅适用于异步函数（并且流似乎会主动忽略任何使用 await 的尝试）

import { parseString } from '@fast-csv/parse';
import * as fs from "fs";

async function IHateStreams (){
    /** Lets read profiles */
    console.log("1: Reading Program " + profileFS);
    let fileContent = fs.readFileSync(profileFS, 'utf8');
    let dataset : Array<any> = []
    return new Promise((resolve, reject) => {
        parseString(fileContent, {headers: true})
            .on('error', error => console.error(error))
            .on('data', row => dataset.push(row))
            .on('end',  () {
                console.log("2: Inside Done")
                resolve
            });
    })

}

IHateStreams().then(console.log("3: stream done!"));
console.log("4: code done, so running next command with the data")

而不是一个很好的输出：

1: Reading Program ./dbinitdata/ProfileIdName.csv
2: Inside Done
3: stream done!
4: code done

我明白了：

1: Reading Program ./dbinitdata/ProfileIdName.csv 
3: stream done! 
4: code done 
2: Inside Done

Answer 1

在所有的闲聊之后，我是如此接近。上面的代码由于 3 个原因而失败。 （如果有人在我的旅程中）

承诺包装似乎有效，上述问题是：

1. 忘记 .then() 特定于流的东西
2. 错别字不会带你去任何地方，resolve()
3. 出于我需要它的目的（不是架构师），创建一个 async 控制函数，并让它假装一切都是顺序的，通过在一个 Promise 中一个又一个流踢一个流。

可能有更简单的方法可以做到这一点，但希望这能带来一些启发。

import { parseString } from '@fast-csv/parse';
import * as fs from "fs";

 const profileFS: string = "tsconfig.json"

async function IHateStreams (){
    /** Lets read profiles */
    console.log("1: Reading Program " + profileFS);
    let fileContent = fs.readFileSync(profileFS, 'utf8');
    let dataset : Array<any> = []
    return new Promise((resolve, reject) => {
        parseString(fileContent, {headers: true})
            .on('error', error => console.error(error))
            .on('data', row => dataset.push(row))
            .on('end',  data => {
                console.log("2: Reading Program " + data);
                resolve();
            }
            });
    })

}
async function iWait (){
    const isThisAPromise = await IHateStreams()
    console.log("3: code done, so running next command with the data")
}

iWait();
console.log("1.99: code done, not in chain")