MSlwk\ReactPhpPlayground\Standalone\ChildProcess\AsynchronousProcessRunner

Complexity

Total Complexity

4

Size/Duplication

Total Lines	53
Duplicated Lines	16.98 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	runProcesses()	0	8	2
A	createProcessDefinition()	9	9	1

<?php
declare(strict_types=1);

/**
 * File: AsynchronousProcessRunner.php
 *
 * @author      Maciej Sławik <maciekslawik@gmail.com>
 * Github:      https://github.com/maciejslawik
 */

namespace MSlwk\ReactPhpPlayground\Standalone\ChildProcess;

use MSlwk\ReactPhpPlayground\Api\Data\ProcessInterface;
use MSlwk\ReactPhpPlayground\Model\Adapter\ReactPHP\ProcessFactory;
use MSlwk\TypeSafeArray\ObjectArray;
use React\EventLoop\LoopInterface;

/**
 * Class AsynchronousProcessRunner
 * @package MSlwk\ReactPhpPlayground\Standalone\ChildProcess
 */
class AsynchronousProcessRunner implements ProcessRunnerInterface
{
    /**
     * @var LoopInterface
     */
    private $loop;

    /**
     * @var ProcessFactory
     */
    private $processFactory;

    /**
     * AsynchronousProcessRunner constructor.
     * @param LoopInterface $loop
     * @param ProcessFactory $processFactory
     */
    public function __construct(
        LoopInterface $loop,
        ProcessFactory $processFactory
    ) {
        $this->loop = $loop;
        $this->processFactory = $processFactory;
    }

    /**
     * @param ObjectArray $processes
     * @return void
     */
    public function runProcesses(ObjectArray $processes): void
    {
        /** @var ProcessInterface $process */
        foreach ($processes as $process) {
            $this->createProcessDefinition($process);
        }
        $this->loop->run();
    }

    /**
     * @codeCoverageIgnore
     * @param ProcessInterface $process
     * @return void
     */
    protected function createProcessDefinition(ProcessInterface $process): void

This method seems to be duplicated in your project.

    {
        $reactProcess = $this->processFactory->create($process->getCommand());
        $reactProcess->start($this->loop);

        $reactProcess->stdout->on('data', function ($chunk) {
            echo $chunk;
        });
    }
}