在 promise 函数中等待

Question

我如何在里面使用 await return new Promise((resolve, reject) => { ... }？这是我的代码：async function write_file(file1, file2){  return new Promise((resolve, reject) => {    const stream = fs_extra.createWriteStream(file2);    stream.write(await fs_extra.readFile(file1), async () => await fs_extra.unlink(file1));    stream.on('finish', () => resolve());    stream.on('error', error => reject(error));    stream.end();  }}我收到语法错误，就像我在非异步函数中使用 await 一样，但即使我在 (resolve, reject) 之前添加了`async，我仍然会收到语法错误...

Answer 1

你没有！并且您也不会将异步函数作为回调传递给write。到那时您已经阅读了该文件，因此您可以立即删除它，或者与其余文件同时删除。

async function write_file(file1, file2) {

  const stream = fs_extra.createWriteStream(file2);

  stream.end(await fs_extra.readFile(file1));

  const unlinkP = fs_extra.unlink(file1);

  unlinkP.catch(() => {});

  // or just await fs_extra.unlink(file1);

  await new Promise((resolve, reject) => {

    stream.on('finish', resolve);

    stream.on('error', reject);

  });

  await unlinkP;

}

stream.end()在收到其finish事件后调用也没有多大意义。

Answer 2

我不知道您想要实现的功能，但如果您想要正确的语法，则如下所示：

async function write_file(file1, file2) {

    return new Promise(async (resolve, reject) => {

        const stream = fs_extra.createWriteStream(file2)

        stream.write(await fs_extra.readFile(file1), async () => await fs_extra.unlink(file1))

        stream.on("finish", () => resolve())

        stream.on("error", error => reject(error))

        stream.end()

    })

}

纠正语法的步骤

在倒数第二个大括号之后放置一个右括号。

在第 2 行添加async before (resolve, reject)。