什麼是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){ 
    ... 
}); 

這裏，回調馬上打電話（與ERR集），如果一個（）返回時走錯了路。 什麼是easy，async.series的基本實現？ 我看了庫async（這太棒了）的代碼，但它是一個圖書館，意味着做了很多的東西，我遇到了麻煩。

你能告訴我一個簡單的async.series實現嗎？它會簡單地調用一個接一個的函數，並且 - 如果其中一個調用帶有錯誤的回調函數 - 調用最終回調函數err set？

謝謝...

芝加哥商業交易所。

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呼叫到達那裏。