我正在尝试重构一些代码,以消除.then嵌套的问题,我需要一些帮助。
我正在尝试压缩一个JSON体,并将其传递到fetch调用中。 我已经成功地完成了这个过程,并在zlib回调函数中调用了fetch,但是代码变得混乱不堪。
因此,我一直在考虑将zlib调用包装在async await包装器中。 例如:
async function syncCompressBody(body) {
//return await compressBody(body);
const compressedData = await compressBody(body);
console.log("compressedData");
console.log(compressedData);
return compressedData;
}
function compressBody(body) {
return new Promise( function( resolve, reject ) {
zlib.deflate(body, (err, buffer) => {
if(err){
console.log("Error Zipping");
reject(err);
}
console.log("Zipped");
resolve(buffer);
});
});
}
compressBody函数返回一个Promise对象。reject和resolve的调用在zlib.deflate的回调函数中。
我实际上使用要压缩的JSON调用syncCompressBody函数。返回值是从compressBody的resolve调用得到的结果。
这两个函数都在一个辅助库中。在我的网页中,作为提交操作的一部分,我有...
console.log(jsonContent);
const compressedBody = syncCompressBody(jsonContent);
console.log(compressedBody);
console.log("should be zipped by now..." + compressedBody);
然而,在compressBody函数中你可以看到“应该压缩”消息之前显示了“已压缩”的消息。我实际上希望代码在返回并恢复提交操作中的JS之前在syncCompressBody中等待。根据Bergi和Liam的评论,我修改了内容,并提供了一个例子,其中包含多个等待,每个函数都依赖于前一个函数...
function awaitStyle2x(){
console.log("pre-awaitStyle2 start");
(async () => {
console.log("awaitStyle2 start")
const t = await theFirstAsyncFunctionX("pass it on");
const u = await theNextAsyncFunctionX(t);
const v = await aThirdAsyncFunctionX(u);
console.log("awaitStyle2 finshed - " + v)
})().catch(e => { /* handle the error */});
console.log("post-awaitStyle2 finished") ;
}
首先显示pre-注释,然后是awaitStyle2开始,接着是theFirstAsyncFunctionX函数中的控制台日志信息,最后是post-消息。
我现在明白了为什么我的代码存在竞态条件,我走在正确的道路上吗?
compressedBody = await syncCompressBody(jsonContent);
- Liamasync function
的promise。这是有道理的,因为你不能使zlib同步化,仍然需要等待它。” - Bergi