ackintosh / snidel

src/Snidel/ResultQueue.php

Unused Use Statements -1 removed lines

@@ -2,7 +2,6 @@
 namespace Ackintosh\Snidel;
 
 use Ackintosh\Snidel\IpcKey;
-use Opis\Closure\SerializableClosure;
 
 class ResultQueue
 {

Doc Comments +4 added lines

@@ -12,6 +12,9 @@ 
 
     private $dequeuedCount = 0;
 
+    /**
+     * @param integer $ownerPid
+     */
     public function __construct($ownerPid)
     {
         $this->ownerPid = $ownerPid;
@@ -21,6 +24,7 @@ 
 
     /**
      * @param   \Ackintosh\Snidel\Fork
+     * @param Fork $fork
      */
     public function enqueue($fork)
     {

src/Snidel/TaskQueue.php

Doc Comments +3 added lines

@@ -11,6 +11,9 @@
     private $queuedCount = 0;
     private $dequeuedCount = 0;
 
+    /**
+     * @param integer $ownerPid
+     */
     public function __construct($ownerPid)
     {
         $this->ownerPid = $ownerPid;

src/Snidel/Task.php

Doc Comments +2 added lines, -2 removed lines

@@ -16,7 +16,7 @@ 
     /**
      * @param   callable    $callable
      * @param   array       $args
-     * @param   string      $string
+     * @param string|null $tag
      */
     public function __construct($callable, $args, $tag)
     {
@@ -60,7 +60,7 @@ 
     }
 
     /**
-     * @return  string|null
+     * @return  string
      */
     public function getTag()
     {

src/Snidel/ForkContainer.php

Doc Comments +9 added lines, -3 removed lines

@@ -45,6 +45,7 @@ 
 
     /**
      * @param   int     $ownerPid
+     * @param Log $log
      */
     public function __construct($ownerPid, $log, $concurrency = 5)
     {
@@ -60,6 +61,7 @@ 
 
     /**
      * @param   \Ackintosh\Snidel\Task
+     * @param Task $task
      * @return  void
      */
     public function enqueue($task)
@@ -155,6 +157,7 @@ 
      * fork worker process
      *
      * @param   \Ackintosh\Snidel\Task
+     * @param Task $task
      * @return  void
      * @throws  \RuntimeException
      */
@@ -262,7 +265,7 @@ 
     }
 
     /**
-     * @return  array
+     * @return  integer[]
      */
     public function getChildPids()
     {
@@ -280,6 +283,9 @@ 
         return $this->forks[$pid];
     }
 
+    /**
+     * @param string $tag
+     */
     public function getCollection($tag = null)
     {
         if ($tag === null) {
@@ -293,7 +299,7 @@ 
      * return forks
      *
      * @param   string  $tag
-     * @return  \Ackintosh\Snidel\Fork[]
+     * @return  ForkCollection
      */
     private function getCollectionWithTag($tag)
     {
@@ -313,7 +319,7 @@ 
     }
 
     /**
-     * @return  \Ackintosh\Sniden\Error
+     * @return  Error
      */
     public function getError()
     {