$eventListeners * @param \Closure(Request):Response $requestHandler */ function processRequest(Request $request, array $eventListeners, \Closure $requestHandler): Response { if (EventInvoker::getPhase($request) !== Phase::Unprocessed) { return $requestHandler($request); } foreach ($eventListeners as $eventListener) { $request->addEventListener($eventListener); } events()->requestStart($request); try { $response = $requestHandler($request); } catch (\Throwable $exception) { events()->requestFailed($request, $exception); throw $exception; } $trailers = $response->getTrailers(); $responseRef = \WeakReference::create($response); $trailers->map(function () use ($request, $responseRef): void { $response = $responseRef->get(); if ($response) { events()->requestEnd($request, $response); } })->ignore(); $trailers->catch(fn (\Throwable $exception) => events()->requestFailed($request, $exception))->ignore(); return $response; }