carno-php / nsq

src/Connector/Nsqd.php

Spacing +5 added lines, -5 removed lines

@@ -128,19 +128,19 @@
     private function protocol() : Events
     {
         return (new Events)
-            ->attach(Events\Socket::CONNECTED, function (Stream $conn) {
+            ->attach(Events\Socket::CONNECTED, function(Stream $conn) {
                 new Handshake($conn, $this, $this->connected);
                 $this->consuming && new Subscribe($this->connected, $this, $this->consuming);
             })
-            ->attach(Events\Socket::RECEIVED, function (Stream $conn) {
-                $this->receiver->inbound($conn->recv(), $this, function () {
+            ->attach(Events\Socket::RECEIVED, function(Stream $conn) {
+                $this->receiver->inbound($conn->recv(), $this, function() {
                     return $this->waiting;
                 }, $this->consuming);
             })
-            ->attach(Events\Socket::CLOSED, function () {
+            ->attach(Events\Socket::CLOSED, function() {
                 $this->disconnected->resolve();
             })
-            ->attach(Events\Socket::ERROR, function () {
+            ->attach(Events\Socket::ERROR, function() {
                 $this->socket && $this->socket->close();
                 $this->destroy();
             })

src/Connector/Linker.php

Spacing +1 added lines, -1 removed lines

@@ -44,7 +44,7 @@
     public function __construct(Endpoint $endpoint, Consuming $consuming = null)
     {
         if (is_null($consuming)) {
-            $this->pool = new Pool(new Options, function () use ($endpoint) {
+            $this->pool = new Pool(new Options, function() use ($endpoint) {
                 return new Nsqd($endpoint);
             }, "nsqd:{$endpoint->service()}");
         } else {

src/Producer.php

Spacing +2 added lines, -2 removed lines

@@ -46,11 +46,11 @@
     protected function background() : Promised
     {
         if ($this->queued()) {
-            $this->exited()->then(function () {
+            $this->exited()->then(function() {
                 $this->chan()->close();
             });
 
-            new Worker($this->chan(), function (array $messages) {
+            new Worker($this->chan(), function(array $messages) {
                 try {
                     yield $this->sending(...$messages);
                 } catch (Throwable $e) {

src/Clustered/Features.php

Spacing +1 added lines, -1 removed lines

@@ -88,7 +88,7 @@
 
         if ($this->consumer) {
             $this->consumer->setTopic($topic)->setChannel($channel);
-            $subscribed->then(function () {
+            $subscribed->then(function() {
                 $this->consumer->startup();
             });
         }

src/Clustered/NOConsumer.php

Spacing +1 added lines, -1 removed lines

@@ -22,7 +22,7 @@
      */
     protected function consuming() : Consuming
     {
-        return new Consuming(function () {
+        return new Consuming(function() {
             // do nothing
         });
     }

src/Consumer.php

Spacing +2 added lines, -2 removed lines

@@ -46,10 +46,10 @@
      */
     protected function background() : Promised
     {
-        return async(function () {
+        return async(function() {
             yield $this->syncedEndpoints(
                 $this->getTopic(),
-                function (int $action, Endpoint $endpoint) {
+                function(int $action, Endpoint $endpoint) {
                     switch ($action) {
                         case Linker::ACT_JOIN:
                             yield $this->linking(

src/Chips/EndpointsRefresher.php

Spacing +3 added lines, -3 removed lines

@@ -28,7 +28,7 @@ 
     protected function lookupEndpoint(Lookupd $lookupd, string $topic)
     {
         if (empty($this->cachedEndpoints)) {
-            $this->cachedEndpoints = yield $lookupd->endpoints($topic, function (array $endpoints) {
+            $this->cachedEndpoints = yield $lookupd->endpoints($topic, function(array $endpoints) {
                 $this->cachedEndpoints = $endpoints;
             });
         }
@@ -45,7 +45,7 @@ 
      */
     protected function syncedEndpoints(string $topic, Closure $linker, Lookupd $lookupd = null, array $statics = [])
     {
-        return $lookupd ? $lookupd->endpoints($topic, function (array $endpoints) use ($linker) {
+        return $lookupd ? $lookupd->endpoints($topic, function(array $endpoints) use ($linker) {
             return $this->routedEndpoints($linker, ...$endpoints);
         }) : $this->routedEndpoints($linker, ...$statics);
     }
@@ -94,7 +94,7 @@ 
         $marked = [];
 
         foreach ($endpoints as $endpoint) {
-            $marked[(string)$endpoint->address()] = $endpoint;
+            $marked[(string) $endpoint->address()] = $endpoint;
         }
 
         return $marked;

src/Chips/N2Daemon.php

Spacing +1 added lines, -1 removed lines

@@ -53,7 +53,7 @@
     {
         $waits = [];
 
-        $this->linkers(function (Linker $linker) use (&$waits) {
+        $this->linkers(function(Linker $linker) use (&$waits) {
             array_push($waits, $linker->disconnect());
         });
 

src/Chips/INSLinker.php

Spacing +3 added lines, -3 removed lines

@@ -29,8 +29,8 @@ 
     protected function linking(Endpoint $endpoint, Consuming $consuming = null) : Linker
     {
         return
-            $this->linked[(string)$endpoint->address()] ??
-            $this->linked[(string)$endpoint->address()] = new Linker($endpoint, $consuming);
+            $this->linked[(string) $endpoint->address()] ??
+            $this->linked[(string) $endpoint->address()] = new Linker($endpoint, $consuming);
     }
 
     /**
@@ -39,7 +39,7 @@ 
      */
     protected function linker(Endpoint $endpoint) : Linker
     {
-        return $this->linked[(string)$endpoint->address()];
+        return $this->linked[(string) $endpoint->address()];
     }
 
     /**