Javascript 将异步回调转换为异步生成器模式

您可以写为¹

async function* transaction() {
    const client = await createClient();
    try {
        await client.query("BEGIN");
        yield client;
    } finally {
        await client.query("COMMIT");
    }
}

并将其用作

for await (const client of transaction()) {
    await client.query("UPDATE ...");
}

但这比目前的水平要高出no better (and much more confusing)

await runTransaction(async client => {
    await client.query("UPDATE ...");
});

这真的没有什么错.它被称为promise disposer pattern，并确保在您完成后对资源进行适当的清理.手动推进异步迭代器的main函数是这种方法错误之处的主要示例:它无法进行错误处理，并且永远不会提交事务.promise 处理者模式防止了这种滥用.

这种模式可能会被explicit resource management proposal美元的一次性用品所取代，这将允许书写

{
    await using client = transaction();
    await client.query("UPDATE ...");
}

_{1:或者甚至把你得到的runTransaction个包装成一个等同的东西，而不是重写它，但这很复杂，我想把这一点弄清楚.}

如果你真的必须这么做，以下是方法:

async function* transaction() {
    // © Bergi, https://stackoverflow.com/a/78043294/1048572, CC BY-SA 4.0
    let final, result, resume; 
    const client = await new Promise((resolve, reject) => {
        final = runTransaction(client => {
            resolve(client);
            return new Promise(resolve => {
                resume = resolve;
            });
        })
        final.catch(reject);
    })
    try {
        result = yield client;
    } catch(err) {
        result = Promise.reject(err);
    } finally {
        resume(result);
        return final;
    }
}

这将处理runTransaction中和回调迭代中所有可能的失败情况，但依赖于runTransaction恰好调用回调一次(除非createClient中有错误).