FM / src

/var/www/vhosts/ihelp.ro/httpdocs/vendor/guzzlehttp/psr7/src/

/var/www/vhosts/ihelp.ro/httpdocs/vendor/guzzlehttp/psr7/src

Name	Size	Mode	Actions
Exception/	-	0755	rm
AppendStream.php	5947	0644	edit dl rm
BufferStream.php	3216	0644	edit dl rm
CachingStream.php	4592	0644	edit dl rm
DroppingStream.php	1196	0644	edit dl rm
FnStream.php	4478	0644	edit dl rm
Header.php	3935	0644	edit dl rm
HttpFactory.php	3072	0644	edit dl rm
InflateStream.php	1387	0644	edit dl rm
LazyOpenStream.php	1088	0644	edit dl rm
LimitStream.php	4297	0644	edit dl rm
Message.php	8315	0644	edit dl rm
MessageTrait.php	7729	0644	edit dl rm
MimeType.php	55037	0644	edit dl rm
MultipartStream.php	5010	0644	edit dl rm
NoSeekStream.php	524	0644	edit dl rm
PumpStream.php	4577	0644	edit dl rm
Query.php	3647	0644	edit dl rm
Request.php	3897	0644	edit dl rm
Response.php	4906	0644	edit dl rm
Rfc7230.php	661	0644	edit dl rm
ServerRequest.php	9549	0644	edit dl rm
Stream.php	7373	0644	edit dl rm
StreamDecoratorTrait.php	3335	0644	edit dl rm
StreamWrapper.php	4041	0644	edit dl rm
UploadedFile.php	4859	0644	edit dl rm
Uri.php	21821	0644	edit dl rm
UriComparator.php	1150	0644	edit dl rm
UriNormalizer.php	8416	0644	edit dl rm
UriResolver.php	8547	0644	edit dl rm
Utils.php	15566	0644	edit dl rm

Edit: /var/www/vhosts/ihelp.ro/httpdocs/vendor/guzzlehttp/psr7/src/PumpStream.php (4577B)

<?php

declare(strict_types=1);

namespace GuzzleHttp\Psr7;

use Psr\Http\Message\StreamInterface;

/**
 * Provides a read only stream that pumps data from a PHP callable.
 *
 * When invoking the provided callable, the PumpStream will pass the amount of
 * data requested to read to the callable. The callable can choose to ignore
 * this value and return fewer or more bytes than requested. Any extra data
 * returned by the provided callable is buffered internally until drained using
 * the read() function of the PumpStream. The provided callable MUST return
 * false when there is no more data to read.
 */
final class PumpStream implements StreamInterface
{
    /** @var callable|null */
    private $source;

/** @var int|null */
    private $size;

/** @var int */
    private $tellPos = 0;

/** @var array */
    private $metadata;

/** @var BufferStream */
    private $buffer;

/**
     * @param callable(int): (string|false|null)  $source  Source of the stream data. The callable MAY
     *                                                     accept an integer argument used to control the
     *                                                     amount of data to return. The callable MUST
     *                                                     return a string when called, or false|null on error
     *                                                     or EOF.
     * @param array{size?: int, metadata?: array} $options Stream options:
     *                                                     - metadata: Hash of metadata to use with stream.
     *                                                     - size: Size of the stream, if known.
     */
    public function __construct(callable $source, array $options = [])
    {
        $this->source = $source;
        $this->size = $options['size'] ?? null;
        $this->metadata = $options['metadata'] ?? [];
        $this->buffer = new BufferStream();
    }

public function __toString(): string
    {
        try {
            return Utils::copyToString($this);
        } catch (\Throwable $e) {
            if (\PHP_VERSION_ID >= 70400) {
                throw $e;
            }
            trigger_error(sprintf('%s::__toString exception: %s', self::class, (string) $e), E_USER_ERROR);

return '';
        }
    }

public function close(): void
    {
        $this->detach();
    }

public function detach()
    {
        $this->tellPos = 0;
        $this->source = null;

return null;
    }

public function getSize(): ?int
    {
        return $this->size;
    }

public function tell(): int
    {
        return $this->tellPos;
    }

public function eof(): bool
    {
        return $this->source === null;
    }

public function isSeekable(): bool
    {
        return false;
    }

public function rewind(): void
    {
        $this->seek(0);
    }

public function seek($offset, $whence = SEEK_SET): void
    {
        throw new \RuntimeException('Cannot seek a PumpStream');
    }

public function isWritable(): bool
    {
        return false;
    }

public function write($string): int
    {
        throw new \RuntimeException('Cannot write to a PumpStream');
    }

public function isReadable(): bool
    {
        return true;
    }

public function read($length): string
    {
        $data = $this->buffer->read($length);
        $readLen = strlen($data);
        $this->tellPos += $readLen;
        $remaining = $length - $readLen;

if ($remaining) {
            $this->pump($remaining);
            $data .= $this->buffer->read($remaining);
            $this->tellPos += strlen($data) - $readLen;
        }

return $data;
    }

public function getContents(): string
    {
        $result = '';
        while (!$this->eof()) {
            $result .= $this->read(1000000);
        }

return $result;
    }

/**
     * @return mixed
     */
    public function getMetadata($key = null)
    {
        if (!$key) {
            return $this->metadata;
        }

return $this->metadata[$key] ?? null;
    }

private function pump(int $length): void
    {
        if ($this->source) {
            do {
                $data = call_user_func($this->source, $length);
                if ($data === false || $data === null) {
                    $this->source = null;

return;
                }
                $this->buffer->write($data);
                $length -= strlen($data);
            } while ($length > 0);
        }
    }
}

source = $source; $this->size = $options['size'] ?? null; $this->metadata = $options['metadata'] ?? []; $this->buffer = new BufferStream(); } public function __toString(): string { try { return Utils::copyToString($this); } catch (\Throwable $e) { if (\PHP_VERSION_ID >= 70400) { throw $e; } trigger_error(sprintf('%s::__toString exception: %s', self::class, (string) $e), E_USER_ERROR); return ''; } } public function close(): void { $this->detach(); } public function detach() { $this->tellPos = 0; $this->source = null; return null; } public function getSize(): ?int { return $this->size; } public function tell(): int { return $this->tellPos; } public function eof(): bool { return $this->source === null; } public function isSeekable(): bool { return false; } public function rewind(): void { $this->seek(0); } public function seek($offset, $whence = SEEK_SET): void { throw new \RuntimeException('Cannot seek a PumpStream'); } public function isWritable(): bool { return false; } public function write($string): int { throw new \RuntimeException('Cannot write to a PumpStream'); } public function isReadable(): bool { return true; } public function read($length): string { $data = $this->buffer->read($length); $readLen = strlen($data); $this->tellPos += $readLen; $remaining = $length - $readLen; if ($remaining) { $this->pump($remaining); $data .= $this->buffer->read($remaining); $this->tellPos += strlen($data) - $readLen; } return $data; } public function getContents(): string { $result = ''; while (!$this->eof()) { $result .= $this->read(1000000); } return $result; } /** * @return mixed */ public function getMetadata($key = null) { if (!$key) { return $this->metadata; } return $this->metadata[$key] ?? null; } private function pump(int $length): void { if ($this->source) { do { $data = call_user_func($this->source, $length); if ($data === false || $data === null) { $this->source = null; return; } $this->buffer->write($data); $length -= strlen($data); } while ($length > 0); } } }