改名

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()
 	{

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());
 	}
 }