This commit is contained in:
2022-09-23 18:55:45 +08:00
parent b3a58b0528
commit 13b9344743
3 changed files with 9 additions and 5 deletions
+4 -2
View File
@@ -89,15 +89,17 @@ class AsyncServer implements ServerInterface
/**
* @return void
* @return bool
* @throws ContainerExceptionInterface
* @throws NotFoundExceptionInterface|ReflectionException
*/
public function shutdown(): void
public function shutdown(): bool
{
$this->server->shutdown();
$this->dispatch->dispatch(new OnShutdown());
return true;
}
+1 -1
View File
@@ -19,7 +19,7 @@ interface OnReceiveInterface
* @param string $data
* @return void
*/
public function onReceive(Server $server, int $fd, int $reactor_id, string $data): void;
public function onReceive(Server $server, int $fd, int $reactor_id, string $data): bool;
}
+4 -2
View File
@@ -34,7 +34,7 @@ class OnServerManager extends Server
* @param \Swoole\Server $server
* @throws ConfigException
* @throws ContainerExceptionInterface
* @throws NotFoundExceptionInterface
* @throws NotFoundExceptionInterface|ReflectionException
*/
public function onManagerStart(\Swoole\Server $server)
{
@@ -46,10 +46,12 @@ class OnServerManager extends Server
/**
* @param \Swoole\Server $server
* @return void
* @throws ContainerExceptionInterface
* @throws NotFoundExceptionInterface
* @throws ReflectionException
*/
public function onManagerStop(\Swoole\Server $server)
public function onManagerStop(\Swoole\Server $server): void
{
$this->dispatch->dispatch(new OnManagerStop($server));
}