使用 Promise 执行流，将一个函数的输出作为下一个函数的输入传递

Question

我正在编写一个具有以程的软件：

Promise.resolve(updateMongoStatus)
  .then(unzipFilesFromS3)
  .then(phase4) //example
  .then(phase5) //example
  .then(processSomething)
  .catch(saveErrorToMongo)

我想知道是否可以将数据从第一个函数传递到最后一个函数，例如：

function updateMongoStatus() {
  // do something here that updates Mongo and get status of some document
  return { status }
}
function unzipFilesFromS3({ status }) {
  // do something here to unzip files from s3
  return { status, files }
}
function phase4({ status, files }) {
  // etc
}

直到processSomething最终被召唤：

function processSomething({ parameterFromOutputOfUpdateMongoStatus, parameterFromPhase4, parameterFromPhase5 }) {
  // Do something here
}

可以吗？像这样传递数据？

谢谢。

Answer 1

是的！这是完全可以的，对于某些人来说，这是通过 Promise 链传递数据的首选方式(因为它不涉及 Promise 块范围之外的任何全局变量/变量(。

在您的情况下，由于您希望在上一个承诺中处于阶段 4、阶段 5 和 mongo 状态，您可以这样做：

Promise
  .resolve(mongoStatus)
  .then((mongoResult) => { 
    return unzipFilesFromS3().then(s3Result => {
      return [s3Result, mongoResult];
    });
})
.then(([ s3Result, mongoResult ]) => {
  return Promise.all([
    mongoResult, 
    s3Result,
    phase4(mongoResult, s3Result) 
  ]);
}) 
// repeat with phase5
.then(([ mongoResult, s3Result, phase4Result /* phase5, etc */ ]) => {
  // etc
})
.catch(err => {});

Answer 2

不，您需要将 promise 对象从 thenable 传递到下一个 thenable。如果只是传递一个值，它将返回该值。

当一个值只是从 then 处理程序中返回时，它将有效地返回 Promise.resolve((。

Promise.prototype.then((

截至14/03/2018的更新：此答案不正确。请参考@Bergi的评论