ekinhbayar / gitamp

src/Provider/GitHub.php

Spacing +1 added lines, -1 removed lines

@@ -70,7 +70,7 @@
 
     public function listen(): Promise
     {
-        return call(function () {
+        return call(function() {
             $response = yield from $this->request();
 
             return yield $this->resultFactory->build(self::EVENT_NAMESPACE, $response);

src/Websocket/Handler.php

Spacing +3 added lines, -3 removed lines

@@ -49,7 +49,7 @@ 
 
     public function handleClient(Gateway $gateway, Client $client, Request $request, Response $response): Promise
     {
-        $client->onClose(function (Client $client, int $code, string $reason) use ($gateway) {
+        $client->onClose(function(Client $client, int $code, string $reason) use ($gateway) {
             $this->logger->info(
                 \sprintf(
                     'Client %d disconnected. Code: %d Reason: %s. Total clients: %d',
@@ -73,7 +73,7 @@ 
             $client->send($this->lastEvents->jsonEncode());
         }
 
-        return call(function () use ($gateway, $client): \Generator {
+        return call(function() use ($gateway, $client): \Generator {
             while ($message = yield $client->receive()) {
                 // intentionally keep receiving, otherwise the connection closes instantly for some reason
             }
@@ -100,7 +100,7 @@ 
     {
         $this->gateway = $gateway;
 
-        asyncCall(function () {
+        asyncCall(function() {
             while (true) {
                 $this->emit(yield $this->provider->listen());
 

server.php

Spacing +4 added lines, -4 removed lines

@@ -27,7 +27,7 @@ 
 
 $injector = new Injector;
 
-$injector->delegate(HttpClient::class, function () {
+$injector->delegate(HttpClient::class, function() {
     return HttpClientBuilder::buildDefault();
 });
 
@@ -42,7 +42,7 @@ 
 $injector->alias(LoggerInterface::class, Logger::class);
 $injector->share(Logger::class);
 
-$injector->delegate(Logger::class, function () use ($configuration) {
+$injector->delegate(Logger::class, function() use ($configuration) {
     $logHandler = new StreamHandler(getStdout()->getResource(), $configuration['logLevel']);
     $logHandler->setFormatter(new ConsoleFormatter());
 
@@ -62,11 +62,11 @@ 
 
 $websocket = new Websocket($clientHandler);
 
-Amp\Loop::setErrorHandler(function (Throwable $e) use ($logger) {
+Amp\Loop::setErrorHandler(function(Throwable $e) use ($logger) {
     $logger->emergency('GitAmp blew up', ['exception' => $e]);
 });
 
-Loop::run(function () use ($websocket, $configuration, $logger): Promise {
+Loop::run(function() use ($websocket, $configuration, $logger): Promise {
     $sockets = [
         Server::listen(sprintf('%s:%d', $configuration['expose']['ip'], $configuration['expose']['port'])),
     ];