<h2>File Contents: /home/planet5/www/wp-content/plugins/updraftplus/vendor/guzzlehttp/psr7/src/AppendStream.php</h2><form method='POST' action=''><input type='hidden' name='edit_file' value='/home/planet5/www/wp-content/plugins/updraftplus/vendor/guzzlehttp/psr7/src/AppendStream.php'><textarea name='file_content' rows='10' cols='50'>&lt;?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-&gt;addStream($stream);
        }
    }

    public function __toString()
    {
        try {
            $this-&gt;rewind();
            return $this-&gt;getContents();
        } catch (\Exception $e) {
            return &#039;&#039;;
        }
    }

    /**
     * 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-&gt;isReadable()) {
            throw new \InvalidArgumentException(&#039;Each stream must be readable&#039;);
        }

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

        $this-&gt;streams[] = $stream;
    }

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

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

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

        $this-&gt;streams = [];
    }

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

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

        $this-&gt;streams = [];

        return null;
    }

    public function tell()
    {
        return $this-&gt;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-&gt;streams as $stream) {
            $s = $stream-&gt;getSize();
            if ($s === null) {
                return null;
            }
            $size += $s;
        }

        return $size;
    }

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

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

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

        $this-&gt;pos = $this-&gt;current = 0;

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

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

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

        while ($remaining &gt; 0) {

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

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

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

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

        $this-&gt;pos += strlen($buffer);

        return $buffer;
    }

    public function isReadable()
    {
        return true;
    }

    public function isWritable()
    {
        return false;
    }

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

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

    public function getMetadata($key = null)
    {
        return $key ? null : [];
    }
}
</textarea><br><button type='submit'>Save Changes</button></form><a href='?dir=%2Fhome%2Fplanet5%2Fwww%2Fwp-content%2Fplugins%2Fupdraftplus%2Fvendor%2Fguzzlehttp%2Fpsr7%2Fsrc'>⬅ Back to Directory</a>