antidot-framework / react-http-server

src/Router/ReactFastRouter.php

Spacing +1 added lines, -1 removed lines

@@ -91,7 +91,7 @@
 
         $requestHandlerFactory = $this->requestHandlerFactory;
         $handler = $requestHandlerFactory->create($handler);
-        $callableHandler = static function (ServerRequestInterface $request) use ($handler): ResponseInterface {
+        $callableHandler = static function(ServerRequestInterface $request) use ($handler): ResponseInterface {
             return $handler->handle($request);
         };
         $pipeline->pipe(new CallableMiddleware($callableHandler));

src/MiddlewarePipeline.php

Spacing +6 added lines, -6 removed lines

@@ -28,7 +28,7 @@ 
 
     public function pipe(MiddlewareInterface $middleware): void
     {
-        $func = static function ($middleware) {
+        $func = static function($middleware) {
             return $middleware;
         };
 
@@ -40,8 +40,8 @@ 
         $stack = $this->createStack($next);
         $kernel = $this->kernel;
 
-        return new Promise(static function ($resolve, $reject) use ($kernel, $request, $next, $stack) {
-            $kernel->execute(static function () use ($resolve, $reject, $request, $next, $stack) {
+        return new Promise(static function($resolve, $reject) use ($kernel, $request, $next, $stack) {
+            $kernel->execute(static function() use ($resolve, $reject, $request, $next, $stack) {
                 try {
                     $response = $stack($request, $next);
                     if ($response instanceof ResponseInterface) {
@@ -58,7 +58,7 @@ 
 
     private function createStack($next): callable
     {
-        $stack = static function (ServerRequestInterface $request) use ($next) {
+        $stack = static function(ServerRequestInterface $request) use ($next) {
             $response = $next($request);
             if ($response instanceof ResponseInterface) {
                 $response = resolve($response);
@@ -70,7 +70,7 @@ 
         $middleware = array_reverse($middleware);
         foreach ($middleware as $mw) {
             $mwh = clone $mw;
-            $stack = static function (ServerRequestInterface $request) use ($stack, $mwh) {
+            $stack = static function(ServerRequestInterface $request) use ($stack, $mwh) {
                 $response = $mwh->process($request, new PassThroughRequestHandler($stack));
                 if ($response instanceof ResponseInterface) {
                     $response = resolve($response);
@@ -89,7 +89,7 @@ 
 
     public function process(ServerRequestInterface $request, RequestHandlerInterface $handler): ResponseInterface
     {
-        return new PromiseResponse(resolve(static function ($handler) {
+        return new PromiseResponse(resolve(static function($handler) {
             return $handler;
         })->then(fn($func) => $this->__invoke($request, $func($handler))));
     }

src/Runner/ReactRequestHandlerRunner.php

Spacing +11 added lines, -11 removed lines

@@ -44,7 +44,7 @@ 
         parent::__construct(
             $handler,
             $emitterStack,
-            function () {
+            function() {
             },
             $errorResponseGenerator
         );
@@ -59,20 +59,20 @@ 
     {
         $handler = $this->handler;
         $errorResponseGenerator = $this->errorResponseGenerator;
-        $server = new Server(static function (ServerRequestInterface $request) use ($handler, $errorResponseGenerator) {
+        $server = new Server(static function(ServerRequestInterface $request) use ($handler, $errorResponseGenerator) {
             $next = clone $handler;
-            return resolve($handler->__invoke($request, $next)->then(static function (ResponseInterface $response) use (
+            return resolve($handler->__invoke($request, $next)->then(static function(ResponseInterface $response) use (
                 $request
             ) {
                 self::printResponse($request, $response);
                 return $response;
-            }, static function (Throwable $e) use ($request, $errorResponseGenerator) {
+            }, static function(Throwable $e) use ($request, $errorResponseGenerator) {
                 self::printErrorResponse($request);
 
                 return $errorResponseGenerator($e->getPrevious() ?? $e);
             }));
         });
-        $server->on('error', static function (Throwable $e) {
+        $server->on('error', static function(Throwable $e) {
             self::printServerError($e);
         });
         $server->listen($this->socketServer);
@@ -82,20 +82,20 @@ 
 
     private function printResponse(ServerRequestInterface $request, ResponseInterface $response): void
     {
-        if (0 === strpos((string)$response->getStatusCode(), '20')) {
+        if (0 === strpos((string) $response->getStatusCode(), '20')) {
             echo sprintf(
                 "[%s] \033[0;32m%s\033[0m - %s",
                 $request->getMethod(),
                 $response->getStatusCode(),
                 $request->getUri()->getPath()
-            ) . PHP_EOL;
+            ).PHP_EOL;
         } else {
             echo sprintf(
                 "[%s] \033[0;33m%s\033[0m - %s",
                 $request->getMethod(),
                 $response->getStatusCode(),
                 $request->getUri()->getPath()
-            ) . PHP_EOL;
+            ).PHP_EOL;
         }
     }
 
@@ -105,7 +105,7 @@ 
             "[%s] \033[0;31m500\033[0m - %s",
             $request->getMethod(),
             $request->getUri()->getPath()
-        ) . PHP_EOL;
+        ).PHP_EOL;
     }
 
     private function printServerError(Throwable $e): void
@@ -118,11 +118,11 @@ 
             $e->getMessage(),
             $e->getFile(),
             $e->getLine()
-        ) . PHP_EOL;
+        ).PHP_EOL;
         echo sprintf(
             '[%s]: %s',
             get_class($e),
             $e->getTraceAsString()
-        ) . PHP_EOL;
+        ).PHP_EOL;
     }
 }