Как правильно прервать цепочку обещаний node.js, используя Q?

Question

Я использую the Q module для Node.js в попытках избежать «пирамиды обречения» в сценариях, где у меня много шагов. Например:

function doTask(task, callback) 
{ 
    Q.ncall(task.step1, task) 
    .then(function(result1){ 
     return Q.ncall(task.step2, task); 
    }) 
    .then(function(result2){ 
     return Q.ncall(task.step3, task); 
    }) 
    .fail(callback).end(); 
} 

По существу это, похоже, работает; если ошибка вызывается каким-либо из шагов задачи, она передается обратному вызову (хотя я был бы рад усовершенствованиям, так как я новичок в обещаниях node.js). Однако у меня есть проблема, когда мне нужно прервать цепочку задач раньше. Например, если result1 успешно вернулся я мог бы вызвать функцию обратного вызова в начале и прервать все остальное, но мои попытки сделать это не удается ...

function doTask(task, callback) 
{ 
    Q.ncall(task.step1, task) 
    .then(function(result1){ 
     if(result1) 
     {// the rest of the task chain is unnecessary 
      console.log('aborting!'); 
      callback(null, result1); 
      return null; 
     } 
     return Q.ncall(task.step2, task); 
    }) 
    .then(function(result2){ 
     console.log('doing step 3...'); 
     return Q.ncall(task.step3, task); 
    }) 
    .fail(callback).end(); 
} 

В этом примере я вижу, как «отбрасывание!» и «сделать шаг 3 ...».

Я уверен, что я просто недопонимаю некоторые основные принципы здесь, поэтому буду признателен за любую помощь. Благодаря!

Answer 1

Любые ошибки, которые выбрасываются в обещание цепи заставит весь стек должен быть прерван в начале и управление передается на ошибки обратного пути. (в этом случае обработчик fail()) Когда вы обнаруживаете определенное состояние, из-за которого вы хотите прервать цепочку обещаний, просто введите очень специфическую ошибку, в которую вы попадаете в обратную ошибку и игнорируете (если вы так выберите)

function doTask(task, callback) 
{ 
    Q.ncall(task.step1, task) 
    .then(function(result1){ 
     if(result1 == 'some failure state I want to cause abortion') 
     {// the rest of the task chain is unnecessary 
      console.log('aborting!'); 
      throw new Error('abort promise chain'); 
      return null; 
     } 
     return Q.ncall(task.step2, task); 
    }) 
    .then(function(result2){ 
     console.log('doing step 3...'); 
     return Q.ncall(task.step3, task); 
    }) 
    .fail(function(err) { 
     if (err.message === 'abort promise chain') { 
      // just swallow error because chain was intentionally aborted 
     } 
     else { 
      // else let the error bubble up because it's coming from somewhere else 
      throw err; 
     } 
    }) 
    .end(); 
} 

Answer 2

Это случай, когда вам нужно разветвиться, что означает либо вложение, либо создание подпрограммы.

function doTask(task, callback) { 
    return Q.ncall(task.step1, task) 
    .then(function(result1) { 
     if (result1) return result1; 
     return Q.ncall(task.step2, task) 
     .then(function(result2) { 
      return Q.ncall(task.step3, task); 
     }) 
    }) 
    .nodeify(callback) 
} 

Или

function doTask(task, callback) { 
    return Q.ncall(task.step1, task) 
    .then(function(result1) { 
     if (result1) { 
      return result1; 
     } else { 
      return continueTasks(task); 
     } 
    }) 
    .nodeify(callback) 
} 

function continueTasks(task) { 
    return Q.ncall(task.step2, task) 
    .then(function(result2) { 
     return Q.ncall(task.step3, task); 
    }) 
} 

Answer 3

Я считаю, что вам нужно отказаться только от обещания вырваться из цепочки обещаний.

https://github.com/kriskowal/q/wiki/API-Reference#qrejectreason

также кажется, что .end() было изменено на .done()

function doTask(task, callback) 
{ 
    Q.ncall(task.step1, task) 
    .then(function(result1){ 
     if(result1) 
     {// the rest of the task chain is unnecessary 
      console.log('aborting!'); 
      // by calling Q.reject, your second .then is skipped, 
      // only the .fail is executed. 
      // result1 will be passed to your callback in the .fail call 
      return Q.reject(result1); 
     } 
     return Q.ncall(task.step2, task); 
    }) 
    .then(function(result2){ 
     console.log('doing step 3...'); 
     return Q.ncall(task.step3, task); 
    }) 
    .fail(callback).done(); 
}