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
2021-08-12 13:48:06 +08:00
parent e794517876
commit a4056c8341
1 changed files with 13 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Server/ServerManager.php
+13
View File
@@ -11,6 +11,8 @@ use Kiri\Kiri;
use ReflectionException; use ReflectionException;
use Server\Manager\OnPipeMessage; use Server\Manager\OnPipeMessage;
use Server\SInterface\CustomProcess; use Server\SInterface\CustomProcess;
use Server\SInterface\OnClose;
use Server\SInterface\OnConnect;
use Server\SInterface\TaskExecute; use Server\SInterface\TaskExecute;
use Server\Task\OnServerTask; use Server\Task\OnServerTask;
use Swoole\Http\Server as HServer; use Swoole\Http\Server as HServer;
@@ -343,6 +345,17 @@ class ServerManager extends Abstracts\Server
foreach ($events as $name => $event) { foreach ($events as $name => $event) {
if (is_array($event) && is_string($event[0])) { if (is_array($event) && is_string($event[0])) {
$event[0] = Kiri::getDi()->get($event[0], [$server]); $event[0] = Kiri::getDi()->get($event[0], [$server]);
// if ($event[0] instanceof OnConnect && $server->getCallback('connect') != null) {
// $server->on('connect', [$event[0], 'onConnect']);
// }
// if ($event[0] instanceof OnClose) {
// if ($server->getCallback('disconnect') != null) {
// $server->on('disconnect', [$event[0], 'onDisconnect']);
// }
// if ($server->getCallback('close') != null) {
// $server->on('close', [$event[0], 'onClose']);
// }
// }
} }
$server->on($name, $event); $server->on($name, $event);
} }