0x20h / phloppy

src/Stream/DefaultStream.php

Doc Comments +2 added lines, -2 removed lines

@@ -188,7 +188,7 @@ 
      * Internal wrapper method, mainly for testing.
      *
      * @param resource $stream
-     * @param          $len
+     * @param          integer|null $len
      *
      * @return string
      */
@@ -214,7 +214,7 @@ 
     /**
      * Internal wrapper method, mainly for testing.
      *
-     * @param $stream
+     * @param resource $stream
      *
      * @return array
      */

src/RespUtils.php

Spacing +2 added lines, -2 removed lines

@@ -24,7 +24,7 @@ 
     {
         return array_reduce(
             $args,
-            function ($msg, $arg) {
+            function($msg, $arg) {
                 return $msg.'$'.strlen($arg)."\r\n".$arg."\r\n";
             },
             '*'.count($args)."\r\n"
@@ -66,7 +66,7 @@ 
                 return trim($stream->readBytes($result + 2));
 
             case '*': // ARRAYS
-                $cnt = (int)$result;
+                $cnt = (int) $result;
                 $out = [];
 
                 for ($i = 0; $i < $cnt; $i++) {

src/Stream/CachingPool.php

Spacing +3 added lines, -3 removed lines

@@ -59,7 +59,7 @@ 
      */
     public function connect()
     {
-        $key = array_reduce($this->nodeUrls, function ($current, $prev) {
+        $key = array_reduce($this->nodeUrls, function($current, $prev) {
             return md5($current.$prev);
         }, '');
 
@@ -100,7 +100,7 @@ 
      */
     public function setCacheTtl($ttl)
     {
-        $this->ttl = (int)$ttl;
+        $this->ttl = (int) $ttl;
     }
 
 
@@ -112,7 +112,7 @@ 
      */
     private function updateNodes($key, StreamInterface $stream)
     {
-        $this->nodeUrls = array_map(function (NodeInfo $element) {
+        $this->nodeUrls = array_map(function(NodeInfo $element) {
             return $element->getServer();
         }, (new Node($stream, $this->log))->hello());
 

src/Event/GetJobsEvent.php

Doc Comments +2 added lines, -2 removed lines

@@ -17,8 +17,8 @@
 
     /**
      * @param string[] $queues
-     * @param          $count
-     * @param          $timeout
+     * @param          integer $count
+     * @param          integer $timeout
      */
     public function __construct(array $queues, $count, $timeout)
     {

src/Statistic/JobOriginStatistic.php

Doc Comments +1 added lines, -1 removed lines

@@ -114,7 +114,7 @@
      *
      * The list is ordered descending by the frequency of Jobs.
      *
-     * @return float[]
+     * @return string
      */
     public function nodes($queue)
     {

Unused Use Statements -1 removed lines

@@ -2,7 +2,6 @@
 
 namespace Phloppy\Statistic;
 
-use Phloppy\Exception;
 use Phloppy\Job;
 use Psr\Log\LoggerInterface;
 use Psr\Log\NullLogger;

src/Statistic/NodeStatistic.php

Doc Comments +1 added lines

@@ -36,6 +36,7 @@
      * If the node is not known, no messages have been retrieved from it, so 0. will be returned.
      *
      * @param $nodeId
+     * @param string $queue
      *
      * @return float
      */

src/Job.php

Spacing +1 added lines, -1 removed lines

@@ -107,7 +107,7 @@
      */
     public function setDelay($delay)
     {
-        $this->delay = (int)$delay;
+        $this->delay = (int) $delay;
     }
 
 

src/Client/AbstractClient.php

Spacing +1 added lines, -1 removed lines

@@ -95,7 +95,7 @@
     protected function mapJobs(array $list)
     {
         return array_map(
-            function ($element) {
+            function($element) {
                 return Job::create([
                     'queue' => $element[0],
                     'id' => $element[1],