改名
This commit is contained in:
@@ -95,8 +95,7 @@ class WebSocket extends Server
|
|||||||
|
|
||||||
/** @var AWebsocket $manager */
|
/** @var AWebsocket $manager */
|
||||||
$manager = Snowflake::get()->annotation->get('websocket');
|
$manager = Snowflake::get()->annotation->get('websocket');
|
||||||
$path = $manager->getName(AWebsocket::MESSAGE, $frame->data['route']);
|
$manager->runWith($manager->getName(AWebsocket::MESSAGE, [0, $frame->data['route']]), [$frame, $server]);
|
||||||
$manager->runWith($path, [$frame, $server]);
|
|
||||||
} catch (Exception $exception) {
|
} catch (Exception $exception) {
|
||||||
$this->application->addError($exception->getMessage(), 'websocket');
|
$this->application->addError($exception->getMessage(), 'websocket');
|
||||||
$server->send($frame->fd, $exception->getMessage());
|
$server->send($frame->fd, $exception->getMessage());
|
||||||
|
|||||||
Reference in New Issue
Block a user