Provides a way to continuously write to the input of a Process until the InputStream is closed. More...

Inheritance diagram for Symfony\Component\Process\InputStream:

Collaboration diagram for Symfony\Component\Process\InputStream:

Public Member Functions
	onEmpty (callable $onEmpty=null)
	Sets a callback that is called when the write buffer becomes empty. More...

	write ($input)
	Appends an input to the write buffer. More...

	close ()
	Closes the write buffer. More...

	isClosed ()
	Tells whether the write buffer is closed or not. More...

	getIterator ()

Private Attributes
	$onEmpty = null

	$input = array()

	$open = true

Detailed Description

Provides a way to continuously write to the input of a Process until the InputStream is closed.

Author: Nicolas Grekas p@tch.nosp@m.work.nosp@m..com

Definition at line 21 of file InputStream.php.

Member Function Documentation

◆ close()

Symfony\Component\Process\InputStream::close ( )

Closes the write buffer.

Definition at line 54 of file InputStream.php.

    {
        $this->open = false;
    }

◆ getIterator()

Symfony\Component\Process\InputStream::getIterator ( )

Definition at line 67 of file InputStream.php.

    {
        $this->open = true;
 
        while ($this->open || $this->input) {
            if (!$this->input) {
                yield '';
                continue;
            }
            $current = array_shift($this->input);
 
            if ($current instanceof \Iterator) {
                foreach ($current as $cur) {
                    yield $cur;
                }
            } else {
                yield $current;
            }
            if (!$this->input && $this->open && null !== $onEmpty = $this->onEmpty) {
                $this->write($onEmpty($this));
            }
        }
    }

References Symfony\Component\Process\InputStream\$onEmpty, input, Symfony\Component\Process\InputStream\onEmpty(), and Symfony\Component\Process\InputStream\write().

Here is the call graph for this function:

◆ isClosed()

Symfony\Component\Process\InputStream::isClosed ( )

Tells whether the write buffer is closed or not.

Definition at line 62 of file InputStream.php.

    {
        return !$this->open;
    }

References Symfony\Component\Process\InputStream\$open.

Referenced by Symfony\Component\Process\InputStream\write().

Here is the caller graph for this function:

◆ onEmpty()

Symfony\Component\Process\InputStream::onEmpty ( callable $onEmpty = null )

Sets a callback that is called when the write buffer becomes empty.

Definition at line 30 of file InputStream.php.

    {
        $this->onEmpty = $onEmpty;
    }

References Symfony\Component\Process\InputStream\$onEmpty, and Symfony\Component\Process\InputStream\onEmpty().

Referenced by Symfony\Component\Process\InputStream\getIterator(), and Symfony\Component\Process\InputStream\onEmpty().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ write()

Symfony\Component\Process\InputStream::write ( $input )

Appends an input to the write buffer.

Parameters

resource|scalar|

Traversable|null The input to append as stream resource, scalar or \Traversable

Definition at line 40 of file InputStream.php.

    {
        if (null === $input) {
            return;
        }
        if ($this->isClosed()) {
            throw new RuntimeException(sprintf('%s is closed', static::class));
        }
        $this->input[] = ProcessUtils::validateInput(__METHOD__, $input);
    }