fix ? (not tested

sern-handler · Mar 16, 2024 · 0d722de · 0d722de
1 parent b191a7a
commit 0d722de
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/src/core/operators.ts b/src/core/operators.ts
@@ -63,10 +63,10 @@ export function handleError<C>(crashHandler: ErrorHandling, emitter: Emitter, lo
     return (pload: unknown, caught: Observable<C>) => {
         // This is done to fit the ErrorHandling contract
         const err = pload instanceof Error ? pload : Error(util.inspect(pload, { colors: true }));
-        emitter.emit('error', err);
-        //formatted payload
-        logging?.error({ message: util.inspect(pload) });
-        crashHandler.updateAlive(err);
+        if(!emitter.emit('error', err)) {
+            logging?.error({ message: util.inspect(pload) });
+            crashHandler.updateAlive(err);
+        } 
         return caught;
     };
 }

diff --git a/src/core/structures/services/error-handling.ts b/src/core/structures/services/error-handling.ts
@@ -10,7 +10,7 @@ export class DefaultErrorHandling implements ErrorHandling {
         throw err;
     }
 
-    #keepAlive = 5;
+    #keepAlive = 1;
 
     updateAlive(err: Error) {
         this.#keepAlive--;