src/functions.php ➔ childProcessPromise()

Complexity

Conditions	3
Paths	1

Size

Total Lines

28

Duplication

Lines	10
Ratio	35.71 %

Code Coverage

Tests	13
CRAP Score	3

Importance

Changes

0

<?php
function childProcessPromise(LoopInterface $loop, Process $process)
{
    $deferred = new Deferred();
    $buffers = [
        'stderr' => '',
        'stdout' => '',
    ];

    $process->on('exit', function ($exitCode) use ($deferred, &$buffers) {
        $deferred->resolve(new ProcessOutcome($exitCode, $buffers['stderr'], $buffers['stdout']));
    });

    \WyriHaximus\React\futurePromise($loop, $process)->then(function (Process $process) use ($loop, &$buffers) {
        $process->start($loop);
        if ($process->stderr instanceof ReadableStreamInterface) {

This code seems to be duplicated across your project.

            $process->stderr->on('data', function ($output) use (&$buffers) {
                $buffers['stderr'] .= $output;
            });
        }
        if ($process->stdout instanceof ReadableStreamInterface) {

This code seems to be duplicated across your project.

            $process->stdout->on('data', function ($output) use (&$buffers) {
                $buffers['stdout'] .= $output;
            });
        }
    });

    return $deferred->promise();
}