javascript - Node Coroutines ジェネレーターと Promise による並列フロー制御

Question

co両方を使用して、コルーチンとプロミスを使用して async.js ライブラリの制御フローを模倣しようとしてbluebird.jsいますが、いくつかの問題が発生しています。私のコードは次のとおりです。これはほとんど疑似コードですが、実際のコードは非常に長くなるため、必要に応じて後で実際のコードを追加できます...

 co(function*(){  
    var re = /^\w+([\.-]?\w+)*@\w+([\.-]?\w+)*(\.\w{2,3})+$/;
    var doc = yield People.findOne({email:  req.body.email}).exec();

    var filePath = path.join(__dirname, '../email-template.html');                         
    var html = yield fs.readFileAsync(filePath,'utf8');
    var emailsToSend = [];
    var emailStatuses = [];
    var validEmails = [];

    //make sure email is ok
    req.body.messagesToSend.forEach(function(message){
      if(message.email != null && re.test(message.email))
      { 
        validEmails.push(message);
      }else{
        // mark it as failed...
        emailStatuses.push({success : "FAILURE", email : message.email}); 
      }
    });

    yield Promise.all( validEmails, Promise.coroutine(function * (message){
      try{
        var person = yield People.findOne({email:  message.email }).exec();

        if(person){ 
          emailStatuses.push({status : "Already exists", email : message.email});
        }else{          
          emailsToSend.push({ email: message.email, message: message.text });
          }              
        }// else
      }catch(err){
        emailStatuses.push({status : "FAILURE", email : message.email}); 
      }//
    }));

    if( emailsToSend.length === 0){
      // no valid emails to process so just return              
      return res.status(200).json(emailStatuses);                     
    }// if no emails to send
    else{
      yield Promise.all(emailsToSend, Promise.coroutine(function * (emailMessage){
        try{                   
          var newInvite =  new Invite();  
          newInvite.email = emailMessage.email;
          newInvite.message = emailMessage.message;
          var invite = yield Invite.save();

          // now try to send the email
          var mailHTMl = html.replace( "{{EMAIL_PLACEHOLDER}}", req.body.registeredEmail);  

          var sendmail              = new emailProvider.Email();
          sendmail.setTos(emailMessage.email);
          sendmail.setFrom(common.DEF_EMAIL_SENDER);
          sendmail.setSubject(common.EMAIL_SUBJECT);
          sendmail.setHtml(mailHTMl);

          var successMail = yield emailProvider.send(sendmail);
          emailStatuses.push({status : "SUCCESS", email : emailMessage.email});
        }catch(err){
          //additional logging here which ive removed for purposes of brevity
          emailStatuses.push({status : "FAILURE", email : emailMessage.email});
        }           
      }));

      return res.status(200).json(emailStatuses);           
    }

  }).catch(function(err){
    //additional logging here which ive removed for purposes of brevity
    return res.status(500)
  });

私が抱えている問題は Promise.all にあります。配列を渡すと、約束の拒否やあらゆる種類のエラーがないにもかかわらず、最初の要素のみを処理するように見えます。

Promise.each を使用すると、このコードは機能しますが、シリアルに実行されます。私が達成したいのは、基本的に 2 つの async.foreach を持つ非同期シリーズを持ち、次々に実行され、各配列項目を並行して処理しますが、各配列を次のように順番に処理することです。

async.series([
  async.foreach
  async.foreach
]);

ただし、Promise.each を使用して配列項目ごとにシリアル実行を取得すると、正常に動作するように見えるため、並列実行するためにここで何が欠けているのかわかりません。