carno-php / pool

src/Wrapper/SAR.php

Spacing +2 added lines, -2 removed lines

@@ -32,7 +32,7 @@ 
 
         // MUST use defer because it can exec whatever job be FIN or KILL
         // otherwise conn will never be released
-        yield defer(function ($stage) use (&$conn) {
+        yield defer(function($stage) use (&$conn) {
             if ($conn instanceof Poolable) {
                 $stage instanceof Broken ? $conn->destroy() : $conn->release();
             } elseif ($stage instanceof Poolable) {
@@ -45,7 +45,7 @@ 
 
         // check interrupter
         if ($interrupter) {
-            $interrupter->then(function () use ($conn) {
+            $interrupter->then(function() use ($conn) {
                 return $conn;
             });
         }

src/Pool.php

Spacing +1 added lines, -1 removed lines

@@ -80,7 +80,7 @@
             $this->heartbeat = new Heartbeat($options, $this->connections);
         }
 
-        $this->closed()->then(function () {
+        $this->closed()->then(function() {
             $this->stopping();
             $this->stats->untrack();
             $this->connections->cleanup();

src/Connections.php

Spacing +11 added lines, -11 removed lines

@@ -222,7 +222,7 @@ 
         }
 
         // checking in getWaitQ
-        while (($this->getWaitQ ?! $this->getWaitQ->isEmpty() : false) && $wait = $this->getWaitQ->dequeue()) {
+        while (($this->getWaitQ ? !$this->getWaitQ->isEmpty() : false) && $wait = $this->getWaitQ->dequeue()) {
             if ($wait->pended()) {
                 $wait->resolve($this->setBusying($conn));
                 return;
@@ -275,7 +275,7 @@ 
      */
     private function checking() : void
     {
-        $cleared = ! ($this->cIdleCount() + $this->cBusyCount());
+        $cleared = !($this->cIdleCount() + $this->cBusyCount());
 
         if ($this->exiting) {
             if ($this->pool && ($closed = $this->pool->closed())->pended() && $cleared) {
@@ -317,8 +317,8 @@ 
                 ]
             );
             $this->rsExpanding = $expandSize = $target - $busySize - $idleSize;
-            while ($expandSize -- > 0) {
-                go(function () {
+            while ($expandSize-- > 0) {
+                go(function() {
                     try {
                         /**
                          * @var Poolable $poolable
@@ -336,7 +336,7 @@ 
                             ]
                         );
                     }
-                    $this->rsExpanding --;
+                    $this->rsExpanding--;
                 });
             }
             return $expandSize;
@@ -352,9 +352,9 @@ 
                 ]
             );
             $shrinkSize = ($busySize + $idleSize) - $target;
-            while ($shrinkSize -- > 0) {
+            while ($shrinkSize-- > 0) {
                 if ($this->staIdling->count() > 0) {
-                    if ($this->removeIdling(null, function ($_, Poolable $found) use ($forced) {
+                    if ($this->removeIdling(null, function($_, Poolable $found) use ($forced) {
                         if (($this->recycling && $this->recycling->idling($found->cid())) || $forced) {
                             return true;
                         }
@@ -368,12 +368,12 @@ 
                         break;
                     }
                 }
-                ($closer = Promise::deferred())->then(function (Poolable $conn) {
+                ($closer = Promise::deferred())->then(function(Poolable $conn) {
                     $this->setClosing($conn);
                 });
                 ($got = array_shift($this->staBusying)) && $got->schedule(Poolable::RELEASED, $closer);
             }
-            return - $shrinkSize;
+            return -$shrinkSize;
         }
 
         return 0;
@@ -432,7 +432,7 @@ 
         }
 
         if (is_null($matcher)) {
-            $matcher = static function (Poolable $present, Poolable $found) {
+            $matcher = static function(Poolable $present, Poolable $found) {
                 return $present->cid() === $found->cid();
             };
         }
@@ -440,7 +440,7 @@ 
         $searched = 0;
         $connections = $this->staIdling->count();
 
-        while ($searched ++ < $connections) {
+        while ($searched++ < $connections) {
             $conn = $this->staIdling->pop();
             if ($matcher($any, $conn)) {
                 $close && $this->setClosing($conn);

src/Connector.php

Spacing +1 added lines, -1 removed lines

@@ -83,7 +83,7 @@
 
         if ($created instanceof Promised) {
             // deferred create instance
-            $created->then(function (Poolable $created) {
+            $created->then(function(Poolable $created) {
                 $created->pool($this->pool);
             });
             return $created;

src/Features/Heartbeat.php

Spacing +2 added lines, -2 removed lines

@@ -36,9 +36,9 @@
          * @var Poolable $conn
          */
         while (null !== $conn = $this->conn()->getIdled(false, false)) {
-            $conn->heartbeat()->then(static function () use ($conn) {
+            $conn->heartbeat()->then(static function() use ($conn) {
                 $conn->release();
-            }, static function () use ($conn) {
+            }, static function() use ($conn) {
                 $conn->destroy();
             });
         }

src/Managed.php

Spacing +2 added lines, -2 removed lines

@@ -62,9 +62,9 @@
             return $this->closed;
         }
 
-        ($this->closed = Promise::deferred())->then(function () {
+        ($this->closed = Promise::deferred())->then(function() {
             $this->destroy();
-        }, function () {
+        }, function() {
             $this->destroy();
         });
 

src/Observer.php

Spacing +1 added lines, -1 removed lines

@@ -42,7 +42,7 @@
      */
     public static function watch(Closure $changed) : void
     {
-        new Worker(self::$chan ?? self::$chan = new Channel, static function (array $recv) use ($changed) {
+        new Worker(self::$chan ?? self::$chan = new Channel, static function(array $recv) use ($changed) {
             $changed(...$recv);
         });
     }