diff --git a/Abstracts/AsyncServer.php b/Abstracts/AsyncServer.php index 222b013..09c59df 100644 --- a/Abstracts/AsyncServer.php +++ b/Abstracts/AsyncServer.php @@ -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; } diff --git a/Contract/OnReceiveInterface.php b/Contract/OnReceiveInterface.php index 149ca5d..2e2775e 100644 --- a/Contract/OnReceiveInterface.php +++ b/Contract/OnReceiveInterface.php @@ -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; } diff --git a/Handler/OnServerManager.php b/Handler/OnServerManager.php index 5c3db22..d9a6d34 100644 --- a/Handler/OnServerManager.php +++ b/Handler/OnServerManager.php @@ -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)); }