From 60e2a3dedc951d813cc4beee6b5fd8f455de7342 Mon Sep 17 00:00:00 2001
From: 7ttp <117663341+7ttp@users.noreply.github.com>
Date: Mon, 12 Jan 2026 20:16:43 +0530
Subject: [PATCH] fix(auth): make _notifyAllSubscribers non-blocking to prevent
 callback deadlocks

---
 packages/core/auth-js/src/GoTrueClient.ts | 42 +++++++----------------
 1 file changed, 13 insertions(+), 29 deletions(-)

diff --git a/packages/core/auth-js/src/GoTrueClient.ts b/packages/core/auth-js/src/GoTrueClient.ts
index 634ee99ab..f02487ebb 100644
--- a/packages/core/auth-js/src/GoTrueClient.ts
+++ b/packages/core/auth-js/src/GoTrueClient.ts
@@ -2730,40 +2730,24 @@ export default class GoTrueClient {
     }
   }
 
-  private async _notifyAllSubscribers(
-    event: AuthChangeEvent,
-    session: Session | null,
-    broadcast = true
-  ) {
+  private _notifyAllSubscribers(event: AuthChangeEvent, session: Session | null, broadcast = true) {
     const debugName = `#_notifyAllSubscribers(${event})`
     this._debug(debugName, 'begin', session, `broadcast = ${broadcast}`)
 
-    try {
-      if (this.broadcastChannel && broadcast) {
-        this.broadcastChannel.postMessage({ event, session })
-      }
-
-      const errors: any[] = []
-      const promises = Array.from(this.stateChangeEmitters.values()).map(async (x) => {
-        try {
-          await x.callback(event, session)
-        } catch (e: any) {
-          errors.push(e)
-        }
-      })
-
-      await Promise.all(promises)
-
-      if (errors.length > 0) {
-        for (let i = 0; i < errors.length; i += 1) {
-          console.error(errors[i])
-        }
+    if (this.broadcastChannel && broadcast) {
+      this.broadcastChannel.postMessage({ event, session })
+    }
 
-        throw errors[0]
+    Array.from(this.stateChangeEmitters.values()).forEach((x) => {
+      try {
+        const result: unknown = x.callback(event, session)
+        if (result instanceof Promise) result.catch(console.error)
+      } catch (e) {
+        console.error(e)
       }
-    } finally {
-      this._debug(debugName, 'end')
-    }
+    })
+
+    this._debug(debugName, 'end')
   }
 
   /**