modify plugin name
This commit is contained in:
@@ -59,12 +59,12 @@ class Server extends AbstractServer
|
|||||||
{
|
{
|
||||||
$collector = $this->getContainer()->get(Sender::class);
|
$collector = $this->getContainer()->get(Sender::class);
|
||||||
|
|
||||||
$fds = $this->getContainer()->get(FdCollector::class);
|
// $fds = $this->getContainer()->get(FdCollector::class);
|
||||||
|
|
||||||
if (!$collector->isEstablished($fd)) {
|
if (!$collector->isEstablished($fd)) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
$fds->remove($fd);
|
// $fds->remove($fd);
|
||||||
|
|
||||||
if ($this->callback instanceof OnCloseInterface) {
|
if ($this->callback instanceof OnCloseInterface) {
|
||||||
$this->callback->onClose($fd);
|
$this->callback->onClose($fd);
|
||||||
|
|||||||
Reference in New Issue
Block a user