Làm cách nào để hủy bỏ chuỗi lời hứa của node.js bằng Q?

Question

Tôi đang sử dụng the Q module cho Node.js để tránh "kim tự tháp doom" trong các trường hợp mà tôi có nhiều bước. Ví dụ:

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

Về cơ bản, điều này dường như hiệu quả; nếu một lỗi được ném bởi bất kỳ bước nhiệm vụ nào, nó sẽ được chuyển tới hàm gọi lại (mặc dù tôi sẽ được chào đón để cải tiến, vì tôi là mới đối với các lời hứa của node.js). Tuy nhiên, tôi có một vấn đề khi tôi cần phải hủy bỏ chuỗi nhiệm vụ sớm. Ví dụ, nếu result1 được trả về thành công tôi có thể muốn gọi gọi lại sớm và hủy bỏ phần còn lại, nhưng những nỗ lực của tôi để làm như vậy được không ...

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

Trong ví dụ này, tôi thấy cả hai "hủy!" và "đang thực hiện bước 3 ..." được in.

Tôi chắc chắn rằng tôi chỉ hiểu lầm một số nguyên tắc cơ bản ở đây, vì vậy sẽ đánh giá cao bất kỳ trợ giúp nào. Cảm ơn!

Answer 1

Bất kỳ lỗi được ném trong chuỗi lời hứa sẽ làm cho toàn bộ ngăn xếp để được hủy bỏ sớm và kiểm soát được trao cho các con đường lỗi trở lại. (trong trường hợp này, trình xử lý fail() Khi bạn phát hiện một trạng thái nào đó khiến bạn muốn hủy bỏ chuỗi lời hứa, thì chỉ cần ném một lỗi rất cụ thể, mà bạn bẫy trong lỗi và bỏ qua (nếu bạn chọn)

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

Đây là trường hợp bạn sẽ cần nhánh, điều đó có nghĩa là lồng hoặc tạo chương trình con.

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

Hoặc

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

Tôi tin rằng bạn chỉ phải từ chối lời hứa để thoát khỏi chuỗi lời hứa.

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

cũng nó có vẻ như END() đã được thay đổi để .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(); 
}