(save: () => Promise<void>)
| 53 | }; |
| 54 | |
| 55 | const run = async (save: () => Promise<void>) => { |
| 56 | try { |
| 57 | await save(); |
| 58 | if (!breakerOpen) consecutiveFailures = 0; |
| 59 | } catch (error) { |
| 60 | consecutiveFailures += 1; |
| 61 | if (consecutiveFailures >= failureThreshold) open(error); |
| 62 | throw error; |
| 63 | } |
| 64 | }; |
| 65 | |
| 66 | return { |
| 67 | enqueue(save) { |