javascript - 一起使用 for 循环和异步 waterfall 的最佳方式

Question

我是 Nodejs 的新手，需要一些指导来编写更好的代码。这是我的问题。

我有一个函数，我正在使用异步 waterfall 模型。我想在循环中调用该函数并在中间出现问题时中断循环，否则在 for 循环结束时通知一些结果。但出于某种原因，我收到了未定义的响应。

function myFunc (arg1) {
     async.waterfall(
           [
               function() {
                        //do something
                        callback(null, data);
               },
               function(data, callback) {
                       //do something
                       callback(null, 'done');
               }
           ],
           function(err, result) {
               return {"error" : err, "res" : result};
           }
}

//Here I am calling my function 
for (var d in mydata) {
    var retdata =  myFunc (mydata[d]); //retdata has undefined in it as this line executes before the last function of water fall
    if (retdata.error !== 200) {
          return //  break loop
     }
  }
//Other wise if every thing is fine nofify after the for loop end
console.log ("done");

简而言之，当 waterfall 的最后一个函数出错时，在结束或中断循环时通知结果(如果为真)的正确和最佳方法是什么。

Answer 1

您不能使用同步方法(如 for 循环)并期望您的代码等待异步任务完成。您不能使用 return 从异步函数获取数据。

这是一种使用 async.map 重构代码的方法。注意回调结构。还要确保您指的是 async documentation .

//Async's methods take arrays:

var mydata = {a: 'foo', b: 'bar'};
var myarr;
for (var d in mydata) {
  myarr.push(mydata[d]);    
  // Beware, you might get unwanted Object properties
  // see e.g. http://stackoverflow.com/questions/3010840/loop-through-array-in-javascript/3010848#3010848
}

async.map(myarr, iterator, mapCallback);

function iterator(d, done){
  // async.map will call this once per myarr element, until completion or error
  myFunc(d, function(err, data){
    done(err, data);    
  });
};

function mapCallback(err, mapped){
  // async.map will call this after completion or error
  if(err){
    // Async ALREADY broke the loop for you.
    // Execution doesn't continue if the iterator function callsback with an
    // error.
  };
  console.log("Asynchronous result of passing mydata to myfunc:");
  console.log(mapped);
  // mapped is an array of returned data, in order, matching myarr.
};


function myFunc (arg1, callback) {
  async.waterfall(
  [
    function(done) {
      //do something
      done(null, data);
    },
    function(data, done) {
      //do something
      done(null, 'done');
    }
  ],
  function(err, result) {
    if (result !== 200) {
      return callback('Non-200');  
      // This return is important to end execution so you don't call the callback twice
    }

    callback(err, result);
  }
}