Перенаправить канал, полученный proc_open (), в файл на оставшуюся часть времени процесса

Скажем, в PHP, У меня есть куча юнит-тестов.
Скажем, они требуют, чтобы какая-то служба работала.

В идеале я хочу, чтобы мой скрипт начальной загрузки:

• запустить эту услугу
• ждать, пока служба достигнет желаемого состояния
• ручное управление для выбора модульного тестирования для запуска тестов
• убирать по окончании тестов, корректно завершая службу соответствующим образом
• установить какой-либо способ захвата всех выходных данных из службы по пути регистрации и отладки

Я сейчас пользуюсь proc_open() чтобы инициализировать мой сервис, захватив выходные данные с помощью механизма конвейера, проверив, что сервис переходит в нужное мне состояние, изучив выходные данные.

Однако в этот момент я в замешательстве — как я могу перехватить остальную часть вывода (включая STDERR) на оставшуюся часть сценария, в то же время позволяя выполнять мои модульные тесты?

Я могу подумать о нескольких потенциально долгих решениях, но прежде чем тратить время на их исследование, я хотел бы узнать, сталкивался ли кто-нибудь еще с этой проблемой и какие решения они нашли, если таковые имеются, не влияя на ответ.

Редактировать:

Вот урезанная версия класса, который я инициализирую в своем скрипте начальной загрузки (с new ServiceRunner), для справки:

<?phpnamespace Tests;class ServiceRunner
{
/**
* @var resource[]
*/
private $servicePipes;

/**
* @var resource
*/
private $serviceProc;

/**
* @var resource
*/
private $temp;

public function __construct()
{
// Open my log output buffer
$this->temp = fopen('php://temp', 'r+');

fputs(STDERR,"Launching Service.\n");
$this->serviceProc      = proc_open('/path/to/service', [
0 => array("pipe", "r"),
1 => array("pipe", "w"),
2 => array("pipe", "w"),
], $this->servicePipes);

// Set the streams to non-blocking, so stream_select() works
stream_set_blocking($this->servicePipes[1], false);
stream_set_blocking($this->servicePipes[2], false);

// Set up array of pipes to select on
$readables = [$this->servicePipes[1], $this->servicePipes[2]);

while(false !== ($streams = stream_select($read = $readables, $w = [], $e = [], 1))) {
// Iterate over pipes that can be read from
foreach($read as $stream) {
// Fetch a line of input, and append to my output buffer
if($line = stream_get_line($stream, 8192, "\n")) {
fputs($this->temp, $line."\n");
}

// Break out of both loops if the service has attained the desired state
if(strstr($line, 'The Service is Listening' ) !== false) {
break 2;
}

// If the service has closed one of its output pipes, remove them from those we're selecting on
if($line === false && feof($stream)) {
$readables = array_diff($readables, [$stream]);
}
}
}

/* SOLUTION REQUIRED SOLUTION REQUIRED SOLUTION REQUIRED SOLUTION REQUIRED */
/* Set up the pipes to be redirected to $this->temp here */

register_shutdown_function([$this, 'shutDown']);
}

public function shutDown()
{
fputs(STDERR,"Closing...\n");
fclose($this->servicePipes[0]);
proc_terminate($this->serviceProc, SIGINT);
fclose($this->servicePipes[1]);
fclose($this->servicePipes[2]);
proc_close($this->serviceProc);
fputs(STDERR,"Closed service\n");

$logFile = fopen('log.txt', 'w');

rewind($this->temp);
stream_copy_to_stream($this->temp, $logFile);

fclose($this->temp);
fclose($logFile);
}
}