Wie man eine node.js-Versprechungskette mit Q korrekt abbricht?

Question

Ich benutze the Q module für Node.js in Versuchen, die "Pyramide des Schicksals" in Szenarien zu vermeiden, in denen ich viele Schritte habe. Zum Beispiel:

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

Im Wesentlichen scheint dies zu funktionieren; Wenn ein Fehler von einem der Task-Schritte ausgelöst wird, wird er an den Callback übergeben (obwohl ich Verbesserungen begrüßen würde, da ich neu bei den node.js-Versprechungen bin). Ich habe jedoch ein Problem, wenn ich die Task-Chain vorzeitig abbrechen muss. Zum Beispiel erfolgreich, wenn result1 zurückgegeben könnte ich will früh den Rückruf rufen und den Rest abbrechen, aber meine Versuche, dies zu tun versagen ...

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 diesem Beispiel sehe ich beide „Abbruch!“ und "mache Schritt 3 ..." gedruckt.

Ich bin mir sicher, dass ich nur einige grundlegende Prinzipien hier falsch verstehe, so würde jede Hilfe zu schätzen wissen. Vielen Dank!

Answer 1

Alle Fehler, die innerhalb der Versprechen Kette geworfen wird der gesamte Stapel führen zu früh abgebrochen werden und die Steuerung wird auf den Fehler zurück Weg gegeben. (In diesem Fall, der fail() - Handler) Wenn Sie einen bestimmten Zustand entdecken, der Sie dazu veranlasst, die Versprechungskette abzubrechen, dann werfen Sie einfach einen sehr spezifischen Fehler, den Sie in den Fehler-Trap einfangen und ignorieren (wenn Sie das tun) Wählen Sie)

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

Dies ist ein Fall, in dem Sie verzweigen müssen, was entweder das Verschachteln oder das Erstellen eines Unterprogramms bedeutet.

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

Oder

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

Ich glaube, Sie müssen nur das Versprechen ablehnen, aus der Versprechungskette zu brechen.

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

auch scheint es, wie .end() geändert wurde .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(); 
}