FM / process

/home/techb158/ileadtechnology.com/SSM/vendor/symfony/process/

/home/techb158/ileadtechnology.com/SSM/vendor/symfony/process

Name	Size	Mode	Actions
Exception/	-	0755	rm
Pipes/	-	0755	rm
CHANGELOG.md	3731	0644	edit dl rm
composer.json	757	0644	edit dl rm
ExecutableFinder.php	2576	0644	edit dl rm
InputStream.php	2310	0644	edit dl rm
LICENSE	1065	0644	edit dl rm
PhpExecutableFinder.php	2575	0644	edit dl rm
PhpProcess.php	2462	0644	edit dl rm
Process.php	51457	0644	edit dl rm
ProcessUtils.php	1869	0644	edit dl rm
README.md	477	0644	edit dl rm

Edit: /home/techb158/ileadtechnology.com/SSM/vendor/symfony/process/InputStream.php (2310B)

<?php

/*
 * This file is part of the Symfony package.
 *
 * (c) Fabien Potencier <fabien@symfony.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Symfony\Component\Process;

use Symfony\Component\Process\Exception\RuntimeException;

/**
 * Provides a way to continuously write to the input of a Process until the InputStream is closed.
 *
 * @author Nicolas Grekas <p@tchwork.com>
 */
class InputStream implements \IteratorAggregate
{
    /** @var callable|null */
    private $onEmpty = null;
    private $input = [];
    private $open = true;

/**
     * Sets a callback that is called when the write buffer becomes empty.
     */
    public function onEmpty(callable $onEmpty = null)
    {
        $this->onEmpty = $onEmpty;
    }

/**
     * Appends an input to the write buffer.
     *
     * @param resource|string|int|float|bool|\Traversable|null $input The input to append as scalar,
     *                                                                stream resource or \Traversable
     */
    public function write($input)
    {
        if (null === $input) {
            return;
        }
        if ($this->isClosed()) {
            throw new RuntimeException(sprintf('"%s" is closed.', static::class));
        }
        $this->input[] = ProcessUtils::validateInput(__METHOD__, $input);
    }

/**
     * Closes the write buffer.
     */
    public function close()
    {
        $this->open = false;
    }

/**
     * Tells whether the write buffer is closed or not.
     */
    public function isClosed()
    {
        return !$this->open;
    }

/**
     * @return \Traversable
     */
    public function getIterator()
    {
        $this->open = true;

while ($this->open || $this->input) {
            if (!$this->input) {
                yield '';
                continue;
            }
            $current = array_shift($this->input);

if ($current instanceof \Iterator) {
                yield from $current;
            } else {
                yield $current;
            }
            if (!$this->input && $this->open && null !== $onEmpty = $this->onEmpty) {
                $this->write($onEmpty($this));
            }
        }
    }
}

cmd: