Bluebird.eachが解決したらブレークする

Question

条件が満たされてから残りの部分をスキップするまで配列の各要素をテストしたい。これは私が思いついたコードです、それは働いているようですが、私は実際に安全か予期しない副作用があるか分かりません。他の解決策が歓迎される。

let buddyAdded = false; 
replicaArr = _.keys(ReplicaList); 
Promise.each(replicaArr, function(replicaname) { 
    if (!buddyAdded) { 
    Player.count({ 
     'buddyList': replicaname 
    }, function(err, result) { 
     if (err) { 

     } else if (result < 990) { 

     Player.update({ 
      '_id': buddyObj.buddyId 
     }, { 
      'buddyList': replicaname 
     }, function(err) { 
      if (err) { 

      } else { 
      ReplicaList[replicaname].send(buddyObj); 
      buddyAdded = true; 
      // success stop here and skip all the other array elements 
      return; 
      } 
     }); 
     } 
    }); 
    } 
}); 

Answer 1

、あなたがリストを更新して起こるすべてのエラーをバックに通信することができます自分のバディリスト内の部屋を持つプレイヤーを見つけたときにシリアルに一つずつ選手を列挙し、反復を中止しようとしている場合は、次に、それを行うための1つの方法があります。これがどのように動作するか

はここにあります：私たちは、その後私たちの制御フローのものを使用できるように

1. 使用ブルーバードのPromise.promisifyAll()が自動的Playerオブジェクトのための約束を返すメソッドを作成します。
2. BluebirdのPromise.mapSeries()を使用して、アレイを一度に1つずつ連続して反復処理します。
3. Player.countAsync()とPlayer.updateAsync()のメソッドが正しくシーケンスされ、.mapSeries()から戻ってくるので、次の配列要素への繰り返しを続ける前に完了するのを待ちます。
4. 部屋のあるプレイヤーを見つけ、バディリストを正常に更新したら、特別に例外をスローします。これは現在の約束を拒否し、.mapSeries()に反復を停止させます（あなたが望んだ通りです）。
5. .catch()を上位レベルに追加すると、特別な拒否がテストされ、成功した解決済みの約束に変わります。他のエラーの場合は、引き続き実際のエラーとして伝播させてください。

コード： `プレイヤーを想定すると

// fn will be passed each array element in sequence 
// fn should return a promise that when resolved with a truthy value will stop the iteration 
// and that value will be the resolved value of the promise that is returned from this function 
// Any rejection will stop the iteration with a rejection 
Promise.firstToPassInSequence = function(arr, fn) { 
    let index = 0; 

    function next() { 
     if (index < arr.length) { 
      return Promise.resolve().then(function() { 
       // if fn() throws, this will turn into a rejection 
       // if fn does not return a promise, it is wrapped into a promise 
       return Promise.resolve(fn(arr[index++])).then(function(val) { 
        return val ? val : next(); 
       }); 
      }); 
     } 
     // make sure we always return a promise, even if array is empty 
     return Promise.resolve(null); 
    } 
    return next(); 
}; 


Promise.firstToPassInSequence(replicaArr, function(replicaname) { 
    return Player.countAsync({buddyList: replicaname}).then(function(result) { 
     // if room left in buddy list 
     if (result < 990) { 
      return Player.updateAsync({'_id': buddyObj.buddyId}, {'buddyList': replicaname}).then(function() { 
       ReplicaList[replicaname].send(buddyObj); 
       return replicaname; 
      }); 
     } 
    }); 
});