carno-php / pool

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 @@ 
                             ]
                         );
                     } finally {
-                        $this->rsExpanding --;
+                        $this->rsExpanding--;
                     }
                 });
             }
@@ -353,9 +353,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;
                         }
@@ -369,12 +369,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;
@@ -433,7 +433,7 @@ 
         }
 
         if (is_null($matcher)) {
-            $matcher = static function (Poolable $present, Poolable $found) {
+            $matcher = static function(Poolable $present, Poolable $found) {
                 return $present->cid() === $found->cid();
             };
         }
@@ -441,7 +441,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);