如何有条件地在 .then .catch 链中运行 .then() 函数？

Question

我的代码是这样的：

router.post("/", (req, res, next) => {
foo()
.then((result) => {
    res.send(result)
})
.catch((error) => {
    cosnole.log(error)
})
//I only want the bar() function and everything below it to run if the first promise is rejected and the first .catch function ran
bar()
.then((data) => {
    res.send(data)
})
.catch((error) => {
    console.log(error)
})

})

我只想在第一个 promise 被拒绝并且 .catch 函数触发时才运行 bar() 函数和 .then .catch 函数。

我试过了：

router.post("/", (req, res, next) => {
rejected = false
foo()
.then((result) => {
    res.send(result)
})
.catch((error) => {
    rejected = true
    console.log(error)
})
if(rejected == true)
    bar()
    .then((data) => {
        res.send(data)
    })
    .catch((error) => {
        console.log(error)
    })

})

但是当第一个 foo() 函数的错误被捕获并且 promise 被拒绝时，bar() 函数永远不会被执行。

Answer 1

将调用移动到内部 catch。

router.post("/", (req, res, next) => {
    foo()
    .then((result) => {
        res.send(result)
    })
    .catch((error) => {
        cosnole.log(error);
        return bar()
        .then((data) => {
            res.send(data)
        })
        .catch((error) => {
            console.log(error)
        });
    });
});

Answer 2

正如其他人提到的，您只需将代码移动到 catch 处理程序中。

但是，您可能希望将代码简化并更正为

router.post("/", (req, res, next) => {
    foo().catch(bar).then(result => {
        res.send(result);
    , error => {
        console.error(error);
        res.sendStatus(500); // or next(error) or whatever
    });
})

如果您想记录来自foo 的错误，即使它们由bar 处理，您可能需要

foo().catch(error => {
    console.log(error, "(handled by bar)");
    return bar();
}).…

Answer 3

I/O 调用是异步发生的，因此您的 if 代码会在 res.send() 返回任何响应之前运行。有几种方法可以处理这种情况，这是另一种使用asyn/await 来编写看起来像同步的代码的方法：

router.post("/", async (req, res, next) => {
rejected = false
try {
  await foo()
    .then((result) => {
      res.send(result)
    })
} catch {
  rejected = true
  console.log(error)
}
if(rejected == true)
  bar()
  .then((data) => {
    res.send(data)
  })
  .catch((error) => {
    console.log(error)
  })
})

Answer 4

鉴于代码的异步特性，if (rejected==true) 将始终为 false，因为该代码在第一个 then 或 catch 之前执行。

你可以：

将所有 bar()[...] 代码移入 .catch()

foo()
.then((result) => {
    res.send(result)
})
.catch((error) => {
    console.log(error)
    bar()
    .then((data) => {
        res.send(data)
    })
    .catch((error) => {
        console.log(error)
    })
})

将所有条件执行移到 .catch() 之后的 .then() 中

rejected = false
foo()
.then((result) => {
    res.send(result)
})
.catch((error) => {
    console.log(error)
    rejected = true
})
.then(() => {
  if(rejected) {
    bar()
    .then((data) => {
        res.send(data)
    })
    .catch((error) => {
        console.log(error)
    })
  }
})

Answer 5

尝试返回 bar 以锁住你的承诺。

router.post("/", (req, res, next) => {
    foo()
    .then((result) => {
        res.send(result)
    })
    .catch((error) => {
        console.log(error);
        return bar;
    })
    .then((data) => {
        res.send(data);
    })
    .catch((error) => {
        console.log(error)
    });
});

----------------- 编辑 -----------------

这是一个 ExpressJS 示例的完全可测试副本，其中包含您的问题：

const express = require("express");
const app = express();
const port = process.env.PORT || 4000;

app.get("/", function(req, res) {
    foo = new Promise(function(resolve, reject) {
        // resolve("resolved"); // Uncomment for resolve
        reject("rejected");
    });

    bar = new Promise(function(resolve, reject) {
        resolve("myData");
    });

    foo.then((result) => {
        res.send(result);
    }).catch((error) => {
        console.log(error);
        return bar;
    }).then((data) => {
        res.send(data);
    });
});

app.listen(port, function () {
    console.log("Listening on port: " + port);
});