ekinhbayar / gitamp

src/Websocket/Handler.php

Spacing +4 added lines, -4 removed lines

@@ -49,8 +49,8 @@ 
 
     public function handleClient(Gateway $gateway, Client $client, Request $request, Response $response): Promise
     {
-        return call(function () use ($gateway, $client, $request, $response) {
-            $client->onClose(function (Client $client, int $code, string $reason) use ($gateway) {
+        return call(function() use ($gateway, $client, $request, $response) {
+            $client->onClose(function(Client $client, int $code, string $reason) use ($gateway) {
                 yield $this->processDisconnectingClient($gateway, $client, $code, $reason);
             });
 
@@ -70,7 +70,7 @@ 
 
     private function processDisconnectingClient(Gateway $gateway, Client  $client, int $code, string $reason): Promise
     {
-        return call(function () use ($gateway, $client, $code, $reason) {
+        return call(function() use ($gateway, $client, $code, $reason) {
             $this->logger->info(
                 \sprintf(
                     'Client %d disconnected. Code: %d Reason: %s. Total clients: %d',
@@ -105,7 +105,7 @@ 
     {
         $this->gateway = $gateway;
 
-        asyncCall(function () {
+        asyncCall(function() {
             while (true) {
                 $this->emit(yield $this->provider->listen());
 

src/Response/Results.php

Spacing +1 added lines, -1 removed lines

@@ -29,7 +29,7 @@
      */
     public function appendResponse(string $eventNamespace, Response $response): Promise
     {
-        return call(function () use ($eventNamespace, $response) {
+        return call(function() use ($eventNamespace, $response) {
             try {
                 $bufferedResponse = yield $response->getBody()->buffer();
 

src/Provider/GitHub.php

Spacing +2 added lines, -2 removed lines

@@ -40,7 +40,7 @@ 
 
     private function request(): Promise
     {
-        return call(function () {
+        return call(function() {
             try {
                 $request = new Request(self::API_ENDPOINT, 'GET');
 
@@ -72,7 +72,7 @@ 
 
     public function listen(): Promise
     {
-        return call(function () {
+        return call(function() {
             $response = yield $this->request();
 
             return yield $this->resultFactory->build(self::EVENT_NAMESPACE, $response);

server.php

Spacing +2 added lines, -2 removed lines

@@ -12,12 +12,12 @@
 
 $logger = (new LoggerFactory())->build($configuration->getLogLevel());
 
-Loop::setErrorHandler(function (\Throwable $e) use ($logger): void {
+Loop::setErrorHandler(function(\Throwable $e) use ($logger): void {
     $logger->emergency('GitAmp blew up', ['exception' => $e]);
 });
 
 $server = new Server($logger, $configuration);
 
-Loop::run(function () use ($server) {
+Loop::run(function() use ($server) {
     yield $server->start();
 });

src/Server.php

Spacing +2 added lines, -2 removed lines

@@ -42,12 +42,12 @@
     private function getSockets(): array
     {
         $sockets = array_map(
-            fn (ServerAddress $address) => SocketServer::listen($address->getUri()),
+            fn(ServerAddress $address) => SocketServer::listen($address->getUri()),
             $this->configuration->getServerAddresses(),
         );
 
         $sockets = array_merge($sockets, array_map(
-            fn (SslServerAddress $address) => SocketServer::listen(
+            fn(SslServerAddress $address) => SocketServer::listen(
                 $address->getUri(),
                 (new BindContext())
                     ->withTlsContext((new ServerTlsContext())->withDefaultCertificate($address->getCertificate())),