[Core] Accessible to process instance from fork

php-bundles · Feb 13, 2018 · a7ea96a · a7ea96a
1 parent ec995b5
commit a7ea96a
Show file tree

Hide file tree

Showing 3 changed files with 18 additions and 0 deletions.
diff --git a/Fork/Fork.php b/Fork/Fork.php
@@ -27,6 +27,14 @@ public function __construct(ProcessInterface $process = null)
         $this->process = $process;
     }
 
+    /**
+     * {@inheritdoc}
+     */
+    public function getProcess(): ProcessInterface
+    {
+        return $this->process;
+    }
+
     /**
      * {@inheritdoc}
      */

diff --git a/Fork/ForkInterface.php b/Fork/ForkInterface.php
@@ -46,4 +46,11 @@ public function each(): \Closure;
      * @return ProcessInterface
      */
     public function run(int $processesCount = ProcessInterface::AUTO_DETECT_OF_PROCESSES_QUANTITY): ProcessInterface;
+
+    /**
+     * Returns the ProcessInterface instance.
+     *
+     * @return ProcessInterface
+     */
+    public function getProcess(): ProcessInterface;
 }
diff --git a/Tests/Fork/ForkTest.php b/Tests/Fork/ForkTest.php
@@ -38,6 +38,7 @@ public function testTasksExecuting()
 
         $process->method('fork')->willReturn(true);
 
+        $pid = $process->getPid();
         $fork = new Fork\Fork($process);
 
         $fork
@@ -50,5 +51,7 @@ public function testTasksExecuting()
         $this->assertTrue($task1->isExecuted());
         $this->assertTrue($task2->isExecuted());
         $this->assertTrue($task3->isExecuted());
+
+        $this->assertSame($pid, $fork->getProcess()->getPid());
     }
 }