Gecko [ unitednationsplay.com ]

Name	Size	Permission	Date
BufferedBody.php	3.88 KB	-rw-r--r--	2020-12-04 12:57
ChunkedDecoder.php	5.22 KB	-rw-r--r--	2020-12-04 12:57
ChunkedEncoder.php	2.03 KB	-rw-r--r--	2020-12-04 12:57
CloseProtectionStream.php	2.75 KB	-rw-r--r--	2020-12-04 12:57
EmptyBodyStream.php	2.73 KB	-rw-r--r--	2020-12-04 12:57
HttpBodyStream.php	3.83 KB	-rw-r--r--	2020-12-04 12:57
IniUtil.php	1.09 KB	-rw-r--r--	2020-12-04 12:57
LengthLimitedStream.php	2.7 KB	-rw-r--r--	2020-12-04 12:57
MiddlewareRunner.php	1.58 KB	-rw-r--r--	2020-12-04 12:57
MultipartParser.php	9.06 KB	-rw-r--r--	2020-12-04 12:57
PauseBufferStream.php	4.19 KB	-rw-r--r--	2020-12-04 12:57
ReadableBodyStream.php	3.18 KB	-rw-r--r--	2020-12-04 12:57
RequestHeaderParser.php	11.08 KB	-rw-r--r--	2020-12-04 12:57
Sender.php	6.37 KB	-rw-r--r--	2020-12-04 12:57
StreamingServer.php	14.73 KB	-rw-r--r--	2020-12-04 12:57
Transaction.php	9.73 KB	-rw-r--r--	2020-12-04 12:57
UploadedFile.php	2.58 KB	-rw-r--r--	2020-12-04 12:57

Rename

<?php

namespace React\Http\Io;

use Psr\Http\Message\StreamInterface;

/**
 * [Internal] PSR-7 message body implementation using an in-memory buffer
 *
 * @internal
 */
class BufferedBody implements StreamInterface
{
    private $buffer = '';
    private $position = 0;
    private $closed = false;

public function __construct($buffer)
    {
        $this->buffer = $buffer;
    }

public function __toString()
    {
        if ($this->closed) {
            return '';
        }

$this->seek(0);

return $this->getContents();
    }

public function close()
    {
        $this->buffer = '';
        $this->position = 0;
        $this->closed = true;
    }

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

return null;
    }

public function getSize()
    {
        return $this->closed ? null : \strlen($this->buffer);
    }

public function tell()
    {
        if ($this->closed) {
            throw new \RuntimeException('Unable to tell position of closed stream');
        }

return $this->position;
    }

public function eof()
    {
        return $this->position >= \strlen($this->buffer);
    }

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

public function seek($offset, $whence = \SEEK_SET)
    {
        if ($this->closed) {
            throw new \RuntimeException('Unable to seek on closed stream');
        }

$old = $this->position;

if ($whence === \SEEK_SET) {
            $this->position = $offset;
        } elseif ($whence === \SEEK_CUR) {
            $this->position += $offset;
        } elseif ($whence === \SEEK_END) {
            $this->position = \strlen($this->buffer) + $offset;
        } else {
            throw new \InvalidArgumentException('Invalid seek mode given');
        }

if (!\is_int($this->position) || $this->position < 0) {
            $this->position = $old;
            throw new \RuntimeException('Unable to seek to position');
        }
    }

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

public function isWritable()
    {
        return !$this->closed;
    }

public function write($string)
    {
        if ($this->closed) {
            throw new \RuntimeException('Unable to write to closed stream');
        }

if ($string === '') {
            return 0;
        }

if ($this->position > 0 && !isset($this->buffer[$this->position - 1])) {
            $this->buffer = \str_pad($this->buffer, $this->position, "\0");
        }

$len = \strlen($string);
        $this->buffer = \substr($this->buffer, 0, $this->position) . $string . \substr($this->buffer, $this->position + $len);
        $this->position += $len;

return $len;
    }

public function isReadable()
    {
        return !$this->closed;
    }

public function read($length)
    {
        if ($this->closed) {
            throw new \RuntimeException('Unable to read from closed stream');
        }

if ($length < 1) {
            throw new \InvalidArgumentException('Invalid read length given');
        }

if ($this->position + $length > \strlen($this->buffer)) {
            $length = \strlen($this->buffer) - $this->position;
        }

if (!isset($this->buffer[$this->position])) {
            return '';
        }

$pos = $this->position;
        $this->position += $length;

return \substr($this->buffer, $pos, $length);
    }

public function getContents()
    {
        if ($this->closed) {
            throw new \RuntimeException('Unable to read from closed stream');
        }

if (!isset($this->buffer[$this->position])) {
            return '';
        }

$pos = $this->position;
        $this->position = \strlen($this->buffer);

return \substr($this->buffer, $pos);
    }

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