function AbstractPipes::write

Writes input to stdin.

Throws

InvalidArgumentException When an input iterator yields a non supported value

2 calls to AbstractPipes::write()

UnixPipes::readAndWrite in vendor/symfony/process/Pipes/UnixPipes.php

Reads data in file handles and pipes.

WindowsPipes::readAndWrite in vendor/symfony/process/Pipes/WindowsPipes.php

Reads data in file handles and pipes.

File

vendor/symfony/process/Pipes/AbstractPipes.php, line 89

Class

AbstractPipes

@author Romain Neutron <imprec@gmail.com>

Namespace

Symfony\Component\Process\Pipes

Code

protected function write() : ?array {
    if (!isset($this->pipes[0])) {
        return null;
    }
    $input = $this->input;
    if ($input instanceof \Iterator) {
        if (!$input->valid()) {
            $input = null;
        }
        elseif (\is_resource($input = $input->current())) {
            stream_set_blocking($input, 0);
        }
        elseif (!isset($this->inputBuffer[0])) {
            if (!\is_string($input)) {
                if (!\is_scalar($input)) {
                    throw new InvalidArgumentException(\sprintf('"%s" yielded a value of type "%s", but only scalars and stream resources are supported.', get_debug_type($this->input), get_debug_type($input)));
                }
                $input = (string) $input;
            }
            $this->inputBuffer = $input;
            $this->input
                ->next();
            $input = null;
        }
        else {
            $input = null;
        }
    }
    $r = $e = [];
    $w = [
        $this->pipes[0],
    ];
    // let's have a look if something changed in streams
    if (false === @stream_select($r, $w, $e, 0, 0)) {
        return null;
    }
    foreach ($w as $stdin) {
        if (isset($this->inputBuffer[0])) {
            $written = fwrite($stdin, $this->inputBuffer);
            $this->inputBuffer = substr($this->inputBuffer, $written);
            if (isset($this->inputBuffer[0])) {
                return [
                    $this->pipes[0],
                ];
            }
        }
        if ($input) {
            while (true) {
                $data = fread($input, self::CHUNK_SIZE);
                if (!isset($data[0])) {
                    break;
                }
                $written = fwrite($stdin, $data);
                $data = substr($data, $written);
                if (isset($data[0])) {
                    $this->inputBuffer = $data;
                    return [
                        $this->pipes[0],
                    ];
                }
            }
            if (feof($input)) {
                if ($this->input instanceof \Iterator) {
                    $this->input
                        ->next();
                }
                else {
                    $this->input = null;
                }
            }
        }
    }
    // no input to read on resource, buffer is empty
    if (!isset($this->inputBuffer[0]) && !($this->input instanceof \Iterator ? $this->input
        ->valid() : $this->input)) {
        $this->input = null;
        fclose($this->pipes[0]);
        unset($this->pipes[0]);
    }
    elseif (!$w) {
        return [
            $this->pipes[0],
        ];
    }
    return null;
}