什么是 async.series 的简单实现？

Question

我有两个功能：

function one(next){
  Users.find({}, function(err, docs){
    if( err)
      next( err );
    } else {
      next( null );
    }
  });
}

function two(next){
  Something.find({}, function(err, docs){
    if( err)
      next( err );
    } else {
      next( null );
    }
  });
}

我可以使用异步库：

async.series( [one, two], function( err ){
  ...
});

这里，如果 one() 返回 err，则立即调用回调（设置 err）。 什么是easy，async.series 的 BASIC 实现？ 我查看了库 async 的代码（这太棒了），但它是一个用来做很多事情的库，我在使用它时遇到了很大的麻烦。

你能告诉我一个简单的 async.series 实现吗？它会简单地一个接一个地调用函数，并且——如果其中一个调用带有错误的回调——调用最终的回调并设置err？

谢谢...

佣兵。

Answer 1

一个实现是这样的：

 function async_series ( fn_list, final_callback ) {
     // Do we have any more async functions to execute?
     if (fn_list.length) {
         // Get the function we want to execute:
         var fn = fn_list.shift();
         // Build a nested callback to process remaining functions:
         var callback = function () {
             async_series(fn_list,final_callback);
         };
         // Call the function
         fn(callback);
     }
     else {
         // Nothing left to process? Then call the final callback:
         final_callback();
     }
 }

以上代码不处理结果或错误的处理。要处理错误，我们可以简单地检查回调中的错误条件，并在错误时立即调用最终回调：

 function async_series ( fn_list, final_callback ) {
     if (fn_list.length) {
         var fn = fn_list.shift();
         var callback = function (err) {
             if (err) {
                 final_callback(err); // error, abort
             }
             else {
                 async_series(fn_list,final_callback);
             }
         };
         fn(callback);
     }
     else {
         final_callback(null); // no errors
     }
 }

通过在闭包中跟踪结果数组或将其传递给下一次对 async_series 的调用，可以类似地处理结果。

请注意，最终的最终回调可以假定没有错误，因为它是通过 if(err)(else)async_series 调用到达那里的。