as2252258/kiri-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

改名

Browse Source
This commit is contained in:
Mr·x
2020-11-05 19:23:05 +08:00
parent 6b9134a064
commit 4dc3ff8e6f
1 changed files with 383 additions and 389 deletions
Download Patch File Download Diff File Expand all files Collapse all files
HttpServer/Server.php
+4 -10
View File
@@ -382,21 +382,15 @@ class Server extends Application
*/ */
private function noHttp($newListener, $config) private function noHttp($newListener, $config)
{ {
$class = [
'pack' => $config['resolve']['pack'] ?? null,
'unpack' => $config['resolve']['unpack'] ?? null
];
$this->onBind($newListener, 'connect', [Snowflake::createObject(OnConnect::class), 'onHandler']); $this->onBind($newListener, 'connect', [Snowflake::createObject(OnConnect::class), 'onHandler']);
$this->onBind($newListener, 'close', [Snowflake::createObject(OnClose::class), 'onHandler']); $this->onBind($newListener, 'close', [Snowflake::createObject(OnClose::class), 'onHandler']);
if ($config['type'] == self::TCP) { if ($config['type'] == self::TCP) {
$class['class'] = OnReceive::class; $this->onBind($newListener, 'receive', [$class = new OnReceive(), 'onHandler']);
$callback = Snowflake::createObject($class);
$this->onBind($newListener, 'receive', [$callback, 'onHandler']);
} else { } else {
$class['class'] = OnPacket::class; $this->onBind($newListener, 'packet', [$class = new OnPacket(), 'onHandler']);
$callback = Snowflake::createObject($class);
$this->onBind($newListener, 'packet', [$callback, 'onHandler']);
} }
$class->pack = $config['resolve']['pack'] ?? null;
$class->unpack = $config['resolve']['unpack'] ?? null;
} }