如何将`resolve`注入回调？

Question

我想在 express 中组合中间件以使它们并行，而不是如果您将 app.use(path, /* middlewares *,/ callback) 放入顺序中。

我写了如下函数：

function makeParallelMiddleware(args) {
  let makePromises = (req, res) => args.map((func) => {
    return new Promise((resolve, reject) => {
      console.log('In promise: ' + func.name);
      func(req, res, resolve);
    })
  });
  return (req, res, next) => Promise.all(makePromises(req, res)).then(next())
}

但这似乎不能正常工作。我使用以下两个中间件进行测试：

function middlewareA(req, res, next) {
  req.A = 1;
  console.log('I am in A');
  setTimeout(() => {
    console.log('I am in A delay');
    if (req.C) {
      req.C = 'BA'
    } else {
      req.C = 'A'
    }
    next()
  }, 1000)
}

function middlewareB(req, res, next) {
  req.B = 1;
  if (req.C) {
    req.C = 'AB'
  } else {
    req.C = 'B'
  }
  next()
}

app.get('/parallel', makeParallelMiddleware([middlewareA, middlewareB]) ,(req, res) => {
  res.send(req.C);
});

当我访问/parallel时，我只能得到“B”而不是“BA”。

如何在设置req.C 之前解决promise？如何更正此问题以获得所需的结果？

Answer 1

改变这个：

return (req, res, next) => Promise.all(makePromises(req, res)).then(next())
//                                                   remove parens here ^^ 

到这里：

return (req, res, next) => Promise.all(makePromises(req, res)).then(function(results) {
    next();
});

您是立即调用next()，而不是传递稍后可以通过.then() 方法调用的函数引用。此外，next() 可能不喜欢将数组传递给它，而 .then() 在你的情况下会传递这样的数组，所以最好只包装一个自定义函数并调用普通的 next()。

---

而且，如果您的任何一个 Promise 拒绝它们，如果它们抛出异常，您还需要一些错误处理。