From fce7551dc3df1154398bb7e6c3bbec8b708eab77 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=90=91=E6=9E=97?= Date: Mon, 14 Feb 2022 14:32:53 +0800 Subject: [PATCH] modify plugin name --- kiri-websocket-server/Server.php | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/kiri-websocket-server/Server.php b/kiri-websocket-server/Server.php index b7e1d71b..9c84b45d 100644 --- a/kiri-websocket-server/Server.php +++ b/kiri-websocket-server/Server.php @@ -51,13 +51,12 @@ class Server extends AbstractServer /** - * @param \Swoole\Server $server * @param int $fd */ - public function onClose(\Swoole\Server $server, int $fd): void + public function onClose(int $fd): void { - $clientInfo = $server->getClientInfo($fd); - if (!isset($clientInfo['websocket_status'])) { + $collector = $this->getContainer()->get(Sender::class); + if (!$collector->isEstablished($fd)) { return; } if ($this->callback instanceof OnCloseInterface) {