BREAK-8: add connection-failed event

scality · Jun 10, 2024 · add9193 · add9193
1 parent cdfacd2
commit add9193
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/CircuitBreaker.ts b/src/CircuitBreaker.ts
@@ -62,7 +62,10 @@ export class CircuitBreaker extends EventEmitter {
     }
 
     async _evaluate() {
-        this._evaluatingPromiseHook = Promise.allSettled(this._probes.map(p => p.check()));
+        this._evaluatingPromiseHook = Promise.allSettled(this._probes.map(p => p.check().catch(error => {
+            this.emit('connection-failed', error);
+            return 'failed';
+        })));
         await this._evaluatingPromiseHook;
         this._evaluatingPromiseHook = null;