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; 
} 

最起碼，代碼是（在我看來）一個小清潔劑無論如何