This commit is contained in:
xl
2024-11-15 14:18:20 +08:00
parent edc7371d9b
commit 292ccc84de
+3 -16
View File
@@ -75,9 +75,10 @@ class OnRequest implements OnRequestInterface
*/ */
public function onRequest(Request $request, Response $response): void public function onRequest(Request $request, Response $response): void
{ {
/** @var CQ $PsrRequest */
try { try {
$PsrRequest = $this->initRequestAndResponse($request); /** @var CQ $PsrRequest */
$response = Context::set(ResponseInterface::class, new ConstrictResponse($this->response->contentType));
$PsrRequest = Context::set(RequestInterface::class, CQ::builder($request));
CoordinatorManager::utility(Coordinator::WORKER_START)->yield(); CoordinatorManager::utility(Coordinator::WORKER_START)->yield();
@@ -89,18 +90,4 @@ class OnRequest implements OnRequestInterface
} }
} }
/**
* @param Request $request
* @return ServerRequestInterface
*/
public function initRequestAndResponse(Request $request): ServerRequestInterface
{
$response = new ConstrictResponse($this->response->contentType);
Context::set(ResponseInterface::class, $response);
return Context::set(RequestInterface::class, CQ::builder($request));
}
} }