系统维护工具

山に住む一家は千個の巣から蜂蜜を収穫し、幼い子供たちは新しい畑で5エーカーの野菜を栽培している。系统维护工具

登出

+ / home / studionolh / www / wp-content / plugins / updraftplus / vendor / guzzlehttp / psr7 / src / [ 返回根目录 ]

名称	大小	权限	修改时间
..	-	-	-
AppendStream.php	5.63 KB	-rw-r--r--	2026-06-05 11:59
BufferStream.php	3.01 KB	-rw-r--r--	2026-06-05 11:59
CachingStream.php	4.35 KB	-rw-r--r--	2026-06-05 11:59
DroppingStream.php	1.07 KB	-rw-r--r--	2026-06-05 11:59
FnStream.php	3.87 KB	-rw-r--r--	2026-06-05 11:59
Header.php	2.13 KB	-rw-r--r--	2026-06-05 11:59
InflateStream.php	1.80 KB	-rw-r--r--	2026-06-05 11:59
LazyOpenStream.php	900.00 B	-rw-r--r--	2026-06-05 11:59
LimitStream.php	4.13 KB	-rw-r--r--	2026-06-05 11:59
Message.php	8.08 KB	-rw-r--r--	2026-06-05 11:59
MessageTrait.php	7.67 KB	-rw-r--r--	2026-06-05 11:59
MimeType.php	4.99 KB	-rw-r--r--	2026-06-05 11:59
MultipartStream.php	4.66 KB	-rw-r--r--	2026-06-05 11:59
NoSeekStream.php	439.00 B	-rw-r--r--	2026-06-05 11:59
PumpStream.php	3.99 KB	-rw-r--r--	2026-06-05 11:59
Query.php	3.41 KB	-rw-r--r--	2026-06-05 11:59
Request.php	3.63 KB	-rw-r--r--	2026-06-05 11:59
Response.php	4.70 KB	-rw-r--r--	2026-06-05 11:59
Rfc7230.php	691.00 B	-rw-r--r--	2026-06-05 11:59
ServerRequest.php	9.62 KB	-rw-r--r--	2026-06-05 11:59
Stream.php	6.65 KB	-rw-r--r--	2026-06-05 11:59
StreamDecoratorTrait.php	3.21 KB	-rw-r--r--	2026-06-05 11:59
StreamWrapper.php	3.69 KB	-rw-r--r--	2026-06-05 11:59
UploadedFile.php	7.59 KB	-rw-r--r--	2026-06-05 11:59
Uri.php	22.36 KB	-rw-r--r--	2026-06-05 11:59
UriComparator.php	1.15 KB	-rw-r--r--	2026-06-05 11:59
UriNormalizer.php	8.14 KB	-rw-r--r--	2026-06-05 11:59
UriResolver.php	8.58 KB	-rw-r--r--	2026-06-05 11:59
Utils.php	14.33 KB	-rw-r--r--	2026-06-05 11:59
functions.php	13.09 KB	-rw-r--r--	2026-06-05 11:59
functions_include.php	156.00 B	-rw-r--r--	2026-06-05 11:59

代码编辑器 :AppendStream.php

<?php

namespace GuzzleHttp\Psr7;

use Psr\Http\Message\StreamInterface;

/**
 * Reads from multiple streams, one after the other.
 *
 * This is a read-only stream decorator.
 *
 * @final
 */
class AppendStream implements StreamInterface
{
    /** @var StreamInterface[] Streams being decorated */
    private $streams = [];

private $seekable = true;
    private $current = 0;
    private $pos = 0;

/**
     * @param StreamInterface[] $streams Streams to decorate. Each stream must
     *                                   be readable.
     */
    public function __construct(array $streams = [])
    {
        foreach ($streams as $stream) {
            $this->addStream($stream);
        }
    }

public function __toString()
    {
        try {
            $this->rewind();
            return $this->getContents();
        } catch (\Exception $e) {
            return '';
        }
    }

/**
     * Add a stream to the AppendStream
     *
     * @param StreamInterface $stream Stream to append. Must be readable.
     *
     * @throws \InvalidArgumentException if the stream is not readable
     */
    public function addStream(StreamInterface $stream)
    {
        if (!$stream->isReadable()) {
            throw new \InvalidArgumentException('Each stream must be readable');
        }

// The stream is only seekable if all streams are seekable
        if (!$stream->isSeekable()) {
            $this->seekable = false;
        }

$this->streams[] = $stream;
    }

public function getContents()
    {
        return Utils::copyToString($this);
    }

/**
     * Closes each attached stream.
     *
     * {@inheritdoc}
     */
    public function close()
    {
        $this->pos = $this->current = 0;
        $this->seekable = true;

foreach ($this->streams as $stream) {
            $stream->close();
        }

$this->streams = [];
    }

/**
     * Detaches each attached stream.
     *
     * Returns null as it's not clear which underlying stream resource to return.
     *
     * {@inheritdoc}
     */
    public function detach()
    {
        $this->pos = $this->current = 0;
        $this->seekable = true;

foreach ($this->streams as $stream) {
            $stream->detach();
        }

$this->streams = [];

return null;
    }

public function tell()
    {
        return $this->pos;
    }

/**
     * Tries to calculate the size by adding the size of each stream.
     *
     * If any of the streams do not return a valid number, then the size of the
     * append stream cannot be determined and null is returned.
     *
     * {@inheritdoc}
     */
    public function getSize()
    {
        $size = 0;

foreach ($this->streams as $stream) {
            $s = $stream->getSize();
            if ($s === null) {
                return null;
            }
            $size += $s;
        }

return $size;
    }

public function eof()
    {
        return !$this->streams ||
            ($this->current >= count($this->streams) - 1 &&
             $this->streams[$this->current]->eof());
    }

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

/**
     * Attempts to seek to the given position. Only supports SEEK_SET.
     *
     * {@inheritdoc}
     */
    public function seek($offset, $whence = SEEK_SET)
    {
        if (!$this->seekable) {
            throw new \RuntimeException('This AppendStream is not seekable');
        } elseif ($whence !== SEEK_SET) {
            throw new \RuntimeException('The AppendStream can only seek with SEEK_SET');
        }

$this->pos = $this->current = 0;

// Rewind each stream
        foreach ($this->streams as $i => $stream) {
            try {
                $stream->rewind();
            } catch (\Exception $e) {
                throw new \RuntimeException('Unable to seek stream '
                    . $i . ' of the AppendStream', 0, $e);
            }
        }

// Seek to the actual position by reading from each stream
        while ($this->pos < $offset && !$this->eof()) {
            $result = $this->read(min(8096, $offset - $this->pos));
            if ($result === '') {
                break;
            }
        }
    }

/**
     * Reads from all of the appended streams until the length is met or EOF.
     *
     * {@inheritdoc}
     */
    public function read($length)
    {
        $buffer = '';
        $total = count($this->streams) - 1;
        $remaining = $length;
        $progressToNext = false;

while ($remaining > 0) {

// Progress to the next stream if needed.
            if ($progressToNext || $this->streams[$this->current]->eof()) {
                $progressToNext = false;
                if ($this->current === $total) {
                    break;
                }
                $this->current++;
            }

$result = $this->streams[$this->current]->read($remaining);

// Using a loose comparison here to match on '', false, and null
            if ($result == null) {
                $progressToNext = true;
                continue;
            }

$buffer .= $result;
            $remaining = $length - strlen($buffer);
        }

$this->pos += strlen($buffer);

return $buffer;
    }

public function isReadable()
    {
        return true;
    }

public function isWritable()
    {
        return false;
    }

public function isSeekable()
    {
        return $this->seekable;
    }

public function write($string)
    {
        throw new \RuntimeException('Cannot write to an AppendStream');
    }

public function getMetadata($key = null)
    {
        return $key ? null : [];
    }
}