Deferred.notify() внутри async.whilst() не вызывает обработчик хода до обратного вызова

Question

У меня есть функция, которая возвращает обещание (используя Q), и уведомления, похоже, не происходят в нужное время. OnFulfilled и onRejected callback работают по назначению, но обратный вызов прогресса не срабатывает до тех пор, пока 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; 
} 

по крайней мере, код (на мой взгляд) немного чистых в любом случае