改名

HttpServer/Events/OnConnect.php

@@ -26,11 +26,13 @@ class OnConnect extends Callback
 	public function onHandler(Server $server, int $fd, int $reactorId)
 	{
 		try {
-            defer(fn() => fire(Event::SYSTEM_RESOURCE_RELEASES));
-
+			defer(fn() => fire(Event::SYSTEM_RESOURCE_RELEASES));
 			if (($clientInfo = $server->getClientInfo($fd, $reactorId)) === false) {
 				return;
 			}
+			if (isset($clientInfo['websocket_status'])) {
+				return;
+			}
 			fire($this->getName($clientInfo), [$server, $fd, $reactorId]);
 		} catch (\Throwable $throwable) {
 			$this->addError($throwable, 'connect');

System/Pool/Connection.php

@@ -239,7 +239,7 @@ class Connection extends Pool
 	 * @param bool $isMaster
 	 * @throws Exception
 	 */
-	public function disconnect($coroutineName, $isMaster = false)
+	public function disconnect($coroutineName, bool $isMaster = false)
 	{
 		$coroutineName = $this->name($coroutineName, $isMaster);
 		$this->clean($coroutineName);