async.whilst（）中的Deferred.notify（）在回调之前不会触发进度处理程序

Question

我有一个返回promise（使用Q）的函数，并且通知似乎并没有在正确的时间发生。 onFulfilled和onRejected回调按预期工作，但进度回调只有在async.whilst（）完成运行后才会触发，并立即触发所有内容。

这是函数

function generateSentences(data, num, options) { 
    var deferred = Q.defer(); 
    const markov = new Markov(data, options); 
    markov.buildCorpus() 
     .then(() => { 
      var count = 0; 
      async.whilst(
       function() { return count < num; }, 
       function (callback) { 
        markov.generateSentence() 
         .then(result => { 
          console.log("Count: " + count); 
          deferred.notify(count/num); //update progress 
          count++; 
          callback(null); 
         }, (err) => { 
          deferred.reject(err.toString()); 
          count++; 
         }); 
       }, 
       function (err, n) { 
        //PROGRESS EVENTS DON'T HAPPEN UNTIL HERE 
        deferred.resolve(generatedSentences); //finish 
       } 
      ); 
     }, (err) => console.log(err)); 
    return deferred.promise; 
} 

，这是使用承诺

function generateScript() { 
    fs.readdir(parser.videoBasePath, function (err, files) { 
     parseFiles(files, parser.parse).then((a) => { 
      console.log("Total Lines: " + fullScript.length + "\n"); 
      fullScript = _.shuffle(fullScript); 
      markov.generateSentences(fullScript, 20).then((data) => { 
       console.log(data); 
      }, (err) => { 
       console.log(err); 
      }, (progress) => { 
       console.log(progress); 
      }); 
     }); 
    }); 
} 

我读过一些线程像this说我需要环绕通知（）一个setTimeout的，但它似乎没有影响任何东西。

Answer 1

我读过Promises + async.js不会混合（但找不到任何可以说的东西!!），我真的不明白为什么这应该是一个问题在这种情况下说实话

话虽如此，还有你的代码似乎没有异步成为可能，所以试试这个，看看工程的进度没有更好

function generateSentences(data, num, options) { 
    var deferred = Q.defer(); 
    const markov = new Markov(data, options); 
    const genSentence = count => markov.generateSentence() 
     .then(result => { 
      console.log("Count: " + count); 
      deferred.notify(count/num); //update progress 
      if (count < num) { 
       return genSentence(count + 1); 
      } 
     }); 
    markov.buildCorpus() 
     .then(() => genSentence(0)) 
     .then(() => deferred.resolve(generatedSentences)) //finish 
     .catch(err => deferred.reject(err.toString())); 
    return deferred.promise; 
} 

最起码，代码是（在我看来）一个小清洁剂无论如何