diff --git a/http-server/Abstracts/Websocket.php b/http-server/Abstracts/Websocket.php index 8c2b5ad9..27d8ed96 100644 --- a/http-server/Abstracts/Websocket.php +++ b/http-server/Abstracts/Websocket.php @@ -5,10 +5,8 @@ namespace Server\Abstracts; use Exception; use Kiri\Abstracts\Config; use Kiri\Exception\ConfigException; -use Kiri\Exception\NotFindClassException; use Kiri\Kiri; use ReflectionException; -use Server\Constrict\ResponseEmitter; use Server\Constrict\WebSocketEmitter; use Server\ExceptionHandlerDispatcher; use Server\ExceptionHandlerInterface; @@ -38,7 +36,6 @@ abstract class Websocket extends Server implements OnHandshake, OnMessage, OnClo /** * @throws ReflectionException * @throws ConfigException - * @throws NotFindClassException */ public function init() { diff --git a/http-server/Constrict/WebSocketEmitter.php b/http-server/Constrict/WebSocketEmitter.php index 5f0151c0..fde82fb0 100644 --- a/http-server/Constrict/WebSocketEmitter.php +++ b/http-server/Constrict/WebSocketEmitter.php @@ -3,8 +3,10 @@ namespace Server\Constrict; -use Kiri\Exception\NotFindClassException; +use Exception; +use Kiri\Kiri; use Psr\Http\Message\ResponseInterface; +use Server\ServerManager; /** * @@ -15,13 +17,13 @@ class WebSocketEmitter implements Emitter /** * @param mixed $response - * @param ResponseInterface $emitter - * @throws NotFindClassException - * @throws \ReflectionException - * @throws \Exception + * @param ResponseInterface|\Server\Message\Response $emitter + * @throws Exception */ - public function sender(mixed $response, ResponseInterface $emitter): void + public function sender(mixed $response, ResponseInterface|\Server\Message\Response $emitter): void { -// $response->push($emitter->getClientId(), $emitter->getContent()->getData()); + $server = Kiri::getDi()->get(ServerManager::class)->getServer(); + + $server->push($response->fd, $emitter->getBody()); } }