PHPUnit process is blocked when there's a lot of output and a test with separate process

Author: staabm

src/Util/PHP/DefaultPhpProcess.php

@@ -112,16 +112,64 @@ protected function runProcess(string $job, array $settings): array
 
         $stderr = $stdout = '';
 
-        if (isset($pipes[1])) {
-            $stdout = stream_get_contents($pipes[1]);
+        unset($pipes[0]);
+        $timeout = 5;
 
-            fclose($pipes[1]);
-        }
+        while (true) {
+            $r = $pipes;
+            $w = null;
+            $e = null;
+
+            $n = @stream_select($r, $w, $e, $timeout);
+
+            if ($n === false) {
+                break;
+            }
+
+            if ($n === 0) {
+                proc_terminate($process, 9);
+
+                throw new PhpProcessException(
+                    sprintf(
+                        'Job execution aborted after %d seconds',
+                        $timeout,
+                    ),
+                );
+            }
 
-        if (isset($pipes[2])) {
-            $stderr = stream_get_contents($pipes[2]);
+            if ($n > 0) {
+                foreach ($r as $pipe) {
+                    $pipeOffset = 0;
 
-            fclose($pipes[2]);
+                    foreach ($pipes as $i => $origPipe) {
+                        if ($pipe === $origPipe) {
+                            $pipeOffset = $i;
+
+                            break;
+                        }
+                    }
+
+                    if (!$pipeOffset) {
+                        break;
+                    }
+
+                    $line = fread($pipe, 8192);
+
+                    if ($line === '' || $line === false) {
+                        fclose($pipes[$pipeOffset]);
+
+                        unset($pipes[$pipeOffset]);
+                    } elseif ($pipeOffset === 1) {
+                        $stdout .= $line;
+                    } else {
+                        $stderr .= $line;
+                    }
+                }
+
+                if (empty($pipes)) {
+                    break;
+                }
+            }
         }
 
         proc_close($process);