diff --git a/Coroutine/Http.php b/Coroutine/Http.php index 96b3b3e..5b24b89 100644 --- a/Coroutine/Http.php +++ b/Coroutine/Http.php @@ -10,6 +10,7 @@ use Kiri\Server\ProcessManager; use Kiri\Server\TraitServer; use Kiri\Task\AsyncTaskExecute; use Kiri\Task\CoroutineTaskExecute; +use Kiri\Websocket\Sender; use Psr\Container\ContainerExceptionInterface; use Psr\Container\NotFoundExceptionInterface; use Swoole\Coroutine; @@ -196,6 +197,9 @@ class Http extends Component { $server = new Coroutine\Http\Server($value['host'], $value['port'], null, true); + $sender = $this->getContainer()->get(Sender::class); + $sender->setServer($server); + $this->servers[$value['port']] = $server; $server->handle('/', function (Request $request, Response $response) use ($handshake, $open, $close, $message) {