Hết giờ trong async/await

Question

Tôi đang sử dụng Node.js và TypeScript và tôi đang sử dụng async/await. Đây là trường hợp thử nghiệm của tôi:

async function doSomethingInSeries() { 
    const res1 = await callApi(); 
    const res2 = await persistInDB(res1); 
    const res3 = await doHeavyComputation(res1); 
    return 'simle'; 
} 

Tôi muốn đặt thời gian chờ cho chức năng tổng thể. I E. nếu res1 mất 2 giây, res2 mất 0,5 giây, res3 mất 5 giây Tôi muốn có thời gian chờ sau 3 giây để tôi phát hiện lỗi.

Với setTimeout cuộc gọi bình thường là một vấn đề bởi vì phạm vi bị mất:

async function doSomethingInSeries() { 
    const timerId = setTimeout(function() { 
     throw new Error('timeout'); 
    }); 

    const res1 = await callApi(); 
    const res2 = await persistInDB(res1); 
    const res3 = await doHeavyComputation(res1); 

    clearTimeout(timerId); 

    return 'simle'; 
} 

Và tôi không thể bắt nó với bình thường Promise.catch:

doSomethingInSeries().catch(function(err) { 
    // errors in res1, res2, res3 will be catched here 
    // but the setTimeout thing is not!! 
}); 

Bất kỳ ý tưởng về làm thế nào để giải quyết?

Answer 1

Bạn có thể sử dụng Promise.race để thực hiện một thời gian chờ:

Promise.race([ 
    doSomethingInSeries(), 
    new Promise((_, reject) => setTimeout(() => reject(new Error('timeout')), 11.5e3)) 
]).catch(function(err) { 
    // errors in res1, res2, res3 and the timeout will be caught here 
}) 

Bạn không thể sử dụng mà không cần setTimeout gói nó trong một lời hứa.

Answer 2

Ok tôi thấy cách này:

async function _doSomethingInSeries() { 
    const res1 = await callApi(); 
    const res2 = await persistInDB(res1); 
    const res3 = await doHeavyComputation(res1); 
    return 'simle'; 
} 

async function doSomethingInSeries(): Promise<any> { 
    let timeoutId; 

    const delay = new Promise(function(resolve, reject){ 
    timeoutId = setTimeout(function(){ 
     reject(new Error('timeout')); 
    }, 1000); 
    }); 

    // overall timeout 
    return Promise.race([delay, _doSomethingInSeries()]) 
    .then((res) => { 
     clearTimeout(timeoutId); 
     return res; 
    }); 

} 

lỗi ai?

Những điều có mùi đối với tôi là sử dụng Promises như chiến lược đồng bộ sẽ gửi cho chúng tôi phân bổ quá nhiều đối tượng mà một số chiến lược khác cần nhưng đây là chủ đề không chính xác.