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; } } });