@@ -47,7 +47,7 @@ discard block |
||
| 47 | 47 | $this->setCurrentPipeline($requestId); |
| 48 | 48 | |
| 49 | 49 | return new PromiseResponse(resolve($request)->then( |
| 50 | - function (ServerRequestInterface $request) { |
|
| 50 | + function(ServerRequestInterface $request) { |
|
| 51 | 51 | /** @var string $requestId */ |
| 52 | 52 | $requestId = $request->getAttribute('request_id'); |
| 53 | 53 | try { |
@@ -78,7 +78,7 @@ discard block |
||
| 78 | 78 | $this->setCurrentPipeline($requestId); |
| 79 | 79 | |
| 80 | 80 | return new PromiseResponse(resolve($request) |
| 81 | - ->then(function (ServerRequestInterface $request) use ($handler) { |
|
| 81 | + ->then(function(ServerRequestInterface $request) use ($handler) { |
|
| 82 | 82 | /** @var string $requestId */ |
| 83 | 83 | $requestId = $request->getAttribute('request_id'); |
| 84 | 84 | try { |
@@ -42,7 +42,7 @@ |
||
| 42 | 42 | new LimitConcurrentRequestsMiddleware(($config['max_concurrency']) ?? 100), |
| 43 | 43 | new RequestBodyBufferMiddleware($config['buffer_size'] ?? 4 * 1024 * 1024), // 4 MiB |
| 44 | 44 | new RequestBodyParserMiddleware(), |
| 45 | - static fn (ServerRequestInterface $request): ResponseInterface => $application->handle($request) |
|
| 45 | + static fn(ServerRequestInterface $request): ResponseInterface => $application->handle($request) |
|
| 46 | 46 | ); |
| 47 | 47 | |
| 48 | 48 | return $server; |
@@ -87,13 +87,13 @@ discard block |
||
| 87 | 87 | { |
| 88 | 88 | return new PromiseResponse(resolve($request) |
| 89 | 89 | ->then( |
| 90 | - function (ServerRequestInterface $request) use ($handler): PromiseInterface { |
|
| 90 | + function(ServerRequestInterface $request) use ($handler): PromiseInterface { |
|
| 91 | 91 | $response = new PromiseResponse( |
| 92 | 92 | resolve($request) |
| 93 | - ->then(static function (ServerRequestInterface $request): ServerRequestInterface { |
|
| 93 | + ->then(static function(ServerRequestInterface $request): ServerRequestInterface { |
|
| 94 | 94 | return $request->withAttribute('request_id', Uuid::uuid4()->toString()); |
| 95 | 95 | }) |
| 96 | - ->then(function (ServerRequestInterface $request) use ($handler): ResponseInterface { |
|
| 96 | + ->then(function(ServerRequestInterface $request) use ($handler): ResponseInterface { |
|
| 97 | 97 | try { |
| 98 | 98 | return $this->pipeline->process($request, $handler); |
| 99 | 99 | } catch (Throwable $exception) { |
@@ -111,13 +111,13 @@ discard block |
||
| 111 | 111 | { |
| 112 | 112 | return new PromiseResponse(resolve($request) |
| 113 | 113 | ->then( |
| 114 | - function (ServerRequestInterface $request): PromiseInterface { |
|
| 114 | + function(ServerRequestInterface $request): PromiseInterface { |
|
| 115 | 115 | $response = new PromiseResponse( |
| 116 | 116 | resolve($request) |
| 117 | - ->then(static function (ServerRequestInterface $request): ServerRequestInterface { |
|
| 117 | + ->then(static function(ServerRequestInterface $request): ServerRequestInterface { |
|
| 118 | 118 | return $request->withAttribute('request_id', Uuid::uuid4()->toString()); |
| 119 | 119 | }) |
| 120 | - ->then(function (ServerRequestInterface $request): ResponseInterface { |
|
| 120 | + ->then(function(ServerRequestInterface $request): ResponseInterface { |
|
| 121 | 121 | try { |
| 122 | 122 | return $this->pipeline->handle($request); |
| 123 | 123 | } catch (Throwable $exception) { |