Revert "改名"

This reverts commit fdf58326
This commit is contained in:
2022-01-17 19:04:26 +08:00
parent a8f840bfb2
commit 45cf88e52c
2 changed files with 19 additions and 3 deletions
+10
View File
@@ -28,6 +28,16 @@ class Sender implements WebSocketInterface
} }
/**
* @param AliasServer|Server $server
*/
public function setServer(mixed $server): void
{
$this->server = $server;
}
/** /**
* @param int $fd * @param int $fd
* @param mixed $data * @param mixed $data
+9 -3
View File
@@ -3,15 +3,15 @@
namespace Kiri\Websocket; namespace Kiri\Websocket;
use Exception; use Exception;
use Kiri\Message\Handler\DataGrip;
use Kiri\Abstracts\AbstractServer; use Kiri\Abstracts\AbstractServer;
use Kiri\Message\Handler\DataGrip;
use Kiri\Message\Handler\RouterCollector; use Kiri\Message\Handler\RouterCollector;
use Psr\Container\ContainerExceptionInterface;
use Psr\Container\NotFoundExceptionInterface;
use Kiri\Server\Contract\OnCloseInterface; use Kiri\Server\Contract\OnCloseInterface;
use Kiri\Server\Contract\OnHandshakeInterface; use Kiri\Server\Contract\OnHandshakeInterface;
use Kiri\Server\Contract\OnMessageInterface; use Kiri\Server\Contract\OnMessageInterface;
use Kiri\Server\Contract\OnOpenInterface; use Kiri\Server\Contract\OnOpenInterface;
use Psr\Container\ContainerExceptionInterface;
use Psr\Container\NotFoundExceptionInterface;
use Swoole\Http\Request; use Swoole\Http\Request;
use Swoole\Http\Response; use Swoole\Http\Response;
use Swoole\WebSocket\Frame; use Swoole\WebSocket\Frame;
@@ -32,6 +32,9 @@ class Server extends AbstractServer
public mixed $callback = null; public mixed $callback = null;
public Sender $sender;
/** /**
* @throws ContainerExceptionInterface * @throws ContainerExceptionInterface
* @throws NotFoundExceptionInterface * @throws NotFoundExceptionInterface
@@ -44,6 +47,9 @@ class Server extends AbstractServer
return; return;
} }
$this->callback = $handler->callback[0]; $this->callback = $handler->callback[0];
$this->sender = $this->container->get(Sender::class);
$this->sender->setServer($this->server);
} }