diff --git a/src/OnRequest.php b/src/OnRequest.php index 847bd1b..ee771e2 100644 --- a/src/OnRequest.php +++ b/src/OnRequest.php @@ -75,9 +75,10 @@ class OnRequest implements OnRequestInterface */ public function onRequest(Request $request, Response $response): void { - /** @var CQ $PsrRequest */ 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(); @@ -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)); - } - }