class ProcessStream

final class ProcessStream extends AbstractStream {
    private string $command;
    private bool $interactive = false;
    public function setCommand(string $command) : void {
        $this->command = $command;
    }
    public function setInteractive(bool $interactive) : void {
        $this->interactive = $interactive;
    }
    public function initialize() : void {
        $descriptorSpec = [
            0 => [
                'pipe',
                'r',
            ],
            1 => [
                'pipe',
                'w',
            ],
            2 => [
                'pipe',
                '\\' === \DIRECTORY_SEPARATOR ? 'a' : 'w',
            ],
        ];
        $pipes = [];
        $this->stream = proc_open($this->command, $descriptorSpec, $pipes);
        stream_set_blocking($pipes[2], false);
        if ($err = stream_get_contents($pipes[2])) {
            throw new TransportException('Process could not be started: ' . $err);
        }
        $this->in =& $pipes[0];
        $this->out =& $pipes[1];
        $this->err =& $pipes[2];
    }
    public function terminate() : void {
        if (null !== $this->stream) {
            fclose($this->in);
            $out = stream_get_contents($this->out);
            fclose($this->out);
            $err = stream_get_contents($this->err);
            fclose($this->err);
            if (0 !== ($exitCode = proc_close($this->stream))) {
                $errorMessage = 'Process failed with exit code ' . $exitCode . ': ' . $out . $err;
            }
        }
        parent::terminate();
        if (!$this->interactive && isset($errorMessage)) {
            throw new TransportException($errorMessage);
        }
    }
    protected function getReadConnectionDescription() : string {
        return 'process ' . $this->command;
    }

}