From df0ad3e7f251c0cf5799b8920aae2458926b1fc3 Mon Sep 17 00:00:00 2001
From: Jon Staab <shtaab@gmail.com>
Date: Mon, 14 Oct 2024 13:08:21 -0700
Subject: [PATCH] Catch errors in worker

---
 packages/lib/src/Worker.ts | 12 ++++++++++--
 1 file changed, 10 insertions(+), 2 deletions(-)

diff --git a/packages/lib/src/Worker.ts b/packages/lib/src/Worker.ts
index c0a62f0..0085dc7 100644
--- a/packages/lib/src/Worker.ts
+++ b/packages/lib/src/Worker.ts
@@ -25,14 +25,22 @@ export class Worker<T> {
         this.buffer.push(message)
       } else {
         for (const handler of this.handlers.get(ANY) || []) {
-          await handler(message)
+          try {
+            await handler(message)
+          } catch (e) {
+            console.error(e)
+          }
         }
 
         if (this.opts.getKey) {
           const k = this.opts.getKey(message)
 
           for (const handler of this.handlers.get(k) || []) {
-            await handler(message)
+            try {
+              await handler(message)
+            } catch (e) {
+              console.error(e)
+            }
           }
         }
       }