qqq
This commit is contained in:
@@ -42,19 +42,6 @@ class WebSocket extends Component implements OnHandshakeInterface, OnMessageInte
|
||||
$this->collector = \Kiri::getDi()->get(DataGrip::class)->get('wss');
|
||||
|
||||
$this->handler = $this->collector->query('/', 'GET');
|
||||
$config = \Kiri::getDi()->get(ConfigProvider::class);
|
||||
if ($this->handler->implement(OnHandshakeInterface::class)) {
|
||||
$config->modify('server.ports.events.' . Constant::HANDSHAKE, [$this->handler->getClass(), 'onHandshake']);
|
||||
}
|
||||
if ($this->handler->implement(OnMessageInterface::class)) {
|
||||
$config->modify('server.ports.events.' . Constant::MESSAGE, [$this->handler->getClass(), 'onMessage']);
|
||||
}
|
||||
if ($this->handler->implement(OnDisconnectInterface::class)) {
|
||||
$config->modify('server.ports.events.' . Constant::DISCONNECT, [$this->handler->getClass(), 'onDisconnect']);
|
||||
}
|
||||
if ($this->handler->implement(OnCloseInterface::class)) {
|
||||
$config->modify('server.ports.events.' . Constant::CLOSE, [$this->handler->getClass(), 'onClose']);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
Reference in New Issue
Block a user