Come interrompere correttamente una catena di promemoria node.js utilizzando Q?

Question

Sto utilizzando the Q module per Node.js nei tentativi di evitare la "piramide di sventura" in scenari in cui ho molti passaggi. Ad esempio:

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(); 
} 

In sostanza, questo sembra funzionare; se viene generato un errore da una qualsiasi delle fasi dell'attività, viene passato al callback (anche se sarei benvenuto a miglioramenti, dato che sono nuovo alle promesse di node.js). Tuttavia, ho un problema quando ho bisogno di abortire presto la catena di attività. Ad esempio, se risultato1 viene restituito con successo potrei voler chiamare la callback presto e annullare il resto, ma i miei tentativi in ​​questo senso sono in mancanza di ...

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(); 
} 

In questo esempio, vedo entrambi "abortire!" e "facendo il punto 3 ..." stampato.

Sono sicuro che sto semplicemente fraintendendo alcuni principi di base qui, quindi apprezzerei qualsiasi aiuto. Grazie!

Answer 1

eventuali errori che vengono gettati all'interno della catena promessa causerà l'intero stack di essere interrotta in anticipo e il controllo è dato al percorso di errore-back. (in questo caso, il gestore fail()) Quando rilevi un certo stato che ti costringe ad abortire la catena di promessa, allora fai un errore molto specifico, che intrappoli nel back-error e ignori (se lo fai tu scegliere)

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

Questo è un caso in cui è necessario eseguire la diramazione, che significa nidificare o creare una subroutine.

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) 
} 

O

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

Credo che si debba solo respingere la promessa di uscire dalla catena di promesse.

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

anche Sembra .end() è stato cambiato in .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(); 
}