From 5b93689184dfbe2466e9600ec310c066cf88ea3a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=90=91=E6=9E=97?= Date: Mon, 14 Feb 2022 14:34:56 +0800 Subject: [PATCH] modify plugin name --- kiri-websocket-server/Server.php | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/kiri-websocket-server/Server.php b/kiri-websocket-server/Server.php index 9c84b45d..905e6d9b 100644 --- a/kiri-websocket-server/Server.php +++ b/kiri-websocket-server/Server.php @@ -52,13 +52,20 @@ class Server extends AbstractServer /** * @param int $fd + * @throws ContainerExceptionInterface + * @throws NotFoundExceptionInterface */ public function onClose(int $fd): void { $collector = $this->getContainer()->get(Sender::class); + + $fds = $this->getContainer()->get(FdCollector::class); + if (!$collector->isEstablished($fd)) { return; } + $fds->remove($fd); + if ($this->callback instanceof OnCloseInterface) { $this->callback->onClose($fd); }