nodejsで非同期のシリーズの次の関数の実行を停止する方法はありますか？

Question

async.map(list, function(object, callback) { 
    async.series([ 
     function(callback) { 
     console.log("1"); 

     var booltest = false; 
     // assuming some logic is performed that may or may not change booltest 
     if(booltest) { 
      // finish this current function, move on to next function in series 
     } else { 
      // stop here and just die, dont move on to the next function in the series 
     } 

     callback(null, 'one'); 
     }, 
     function(callback) { 
     console.log("2"); 
     callback(null, 'two'); 
     } 
    ], 
    function(err, done){ 
    }); 
    }); 

function1の場合、booltestがtrueと評価された場合、 "2"を出力する次の関数に移動しないような方法がありますか？あなたがエラー引数として真でコールバックした場合

Answer 1

流れはとても基本的に

if (booltest) 
    callback(null, 'one'); 
else 
    callback(true); 

が、それは論理的にするために

Answer 2

動作するはずです、あなただけのerrorOrStopのようなものにerrorの名前を変更することができ、停止します。

var test = [1,2,3]; 

test.forEach(function(value) { 
    async.series([ 
     function(callback){ something1(i, callback) }, 
     function(callback){ something2(i, callback) } 
    ], 
    function(errorOrStop) { 
     if (errorOrStop) { 
      if (errorOrStop instanceof Error) throw errorOrStop; 
      else return; // stops async for this index of `test` 
     } 
     console.log("done!"); 
    }); 
}); 

function something1(i, callback) { 
    var stop = i<2; 
    callback(stop); 
} 

function something2(i, callback) { 
    var error = (i>2) ? new Error("poof") : null; 
    callback(error); 
} 

Answer 3

あなたが探している機能はasync.detectではないと思います。 https://github.com/caolan/async#detect

から

（ARR、反復子、コールバック）を検出

は非同期真実試験に合格するARRの最初の値を返します。 イテレータが並列に適用されます。つまり、最初のイテレータが を返すと、その結果で検出コールバックが発生します。つまり、 の結果は、テストに合格した元のarrの最初の項目（ の順）ではない可能性があります。

のコード例

async.detect(['file1','file2','file3'], fs.exists, function(result){ 
    // result now equals the first file in the list that exists 
}); 

あなたのbooltestであなたが望む結果を得るためにすることを使用することができます。

Answer 4

エラーと機能だけを区別するためにオブジェクトを渡しています。これは次のようになります。その後

function logAppStatus(status, cb){ 
    if(status == 'on'){ 
    console.log('app is on'); 
    cb(null, status); 
    } 
    else{ 
    cb({'status' : 'functionality', 'message': 'app is turned off'}) // <-- object 
    } 
} 

：

async.waterfall([ 
    getAppStatus, 
    logAppStatus, 
    checkStop 
], function (error) { 
    if (error) { 
     if(error.status == 'error'){ // <-- if it's an actual error 
     console.log(error.message); 
     } 
     else if(error.status == 'functionality'){ <-- if it's just functionality 
     return 
     } 

    } 
});