在 NodeJS 中实现阻塞控制流

Question

我正在尝试创建一个阻塞控制流，但已经走到了死胡同。 这个想法是一个请求进来并流经许多处理函数。每个功能都会做一些事情并决定现在是否满足请求。如果是，则处理停止，如果不是，则调用下一个处理程序。 每个处理程序可能会或可能不会异步执行某些操作（例如获取/写入数据）。如果是这种情况，则以下处理程序依赖于在启动之前存在的数据。

到目前为止，我有两个想法，都不太符合这些要求： 1) 所有处理程序都是函数，它们被推入一个数组并使用 some 进行迭代。如果处理程序希望停止控制流，它只需要返回true。 使用这种方法，我不能让任何处理程序调用异步函数。

2) 所有处理程序都是链接的承诺。这对我来说似乎是一个更好的主意，但我不知道如何最好地处理停止控制流。我有两个想法： - 一旦处理程序决定中断流，保留一个设置为true 的变量。在每个处理程序中检查此值并在需要时立即解决。这意味着很多重复的代码。 - 如果不希望继续正常流程，则拒绝承诺，并继续catch。然而，使用错误来控制流程的想法让我很痛苦——这也意味着我必须处理由于实际错误而调用 catch 的情况。

我的感觉告诉我必须有另一种方法，但我想不通。

Answer 1

您可以根据需要使用 ES6 生成器来生成 Promise。每次 Promise 解决时，它都可以检查停止值，如果为 false（即继续到下一个处理程序），则从迭代器请求下一个。

function* promiseHandlers() {
  const handlers = [
    promiseHandler1,
    promiseHandler2,
    promiseHandler3,
    promiseHandler4,
    promiseHandler5
  ];

  for (const handler of handlers) {
    yield handler();
  }
}

function run(iter) {
  const i = iter.next();
  if (i.done) {
    return Promise.reject(new Error("end of iterator reached"));
  }
  return Promise.resolve(i.value).then(result => result || run(iter));
}

run(promiseHandlers());

这实际上并不是链接。相反，它会按顺序执行每个 promiseHandler，但这些结果不会传递给下一个。我认为这对于 OP 想要的东西是正确的，特别是因为真实的结果结束了迭​​代（即中断）。

Answer 2

不要链接承诺处理程序，嵌套它们。您可以通过一组函数以编程方式执行此操作：

var handlers = […]; // functions that can return promises

var run = handlers.reduceRight(function(next, handler) {
    return function() {
        return Promise.resolve(someArg).then(handler).then(function(result) {
            if (result) // true, whatever
                return result;
            else
                return next();
        });
    };
}, function end() {
    return Promise.reject(new Error("no handler matched"));
});

run().then(function(result) {
    // the result from the first handler that returned anything
}, function(err) {
    // some handler threw an exception, or there was no handler
});