From 7d9a25a13e48062d890c0b7a05933a1205edabf8 Mon Sep 17 00:00:00 2001
From: kafkiansky <vadimzanfir@gmail.com>
Date: Tue, 17 Mar 2026 19:32:48 +0300
Subject: [PATCH] Error handling in `SocketConnection::run()`

---
 src/Internal/Connection/SocketConnection.php | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/src/Internal/Connection/SocketConnection.php b/src/Internal/Connection/SocketConnection.php
index 0c2eff3..0a4236c 100644
--- a/src/Internal/Connection/SocketConnection.php
+++ b/src/Internal/Connection/SocketConnection.php
@@ -171,6 +171,11 @@ private function run(): void
                     foreach ($queue as $deferred) {
                         $deferred->error($e);
                     }
+
+                    $running = false;
+                    $hooks->dispatch(Hooks\ConnectionClosed::Event);
+
+                    return;
                 }
             }
         });