<?php namespace GuzzleHttp\Psr7; use Psr\Http\Message\StreamInterface; /** * Stream decorator trait * @property StreamInterface stream */ trait StreamDecoratorTrait { /** * @param StreamInterface $stream Stream to decorate */ public function __construct(StreamInterface $stream) { $this->stream = $stream; } /** * Magic method used to create a new stream if streams are not added in * the constructor of a decorator (e.g., LazyOpenStream). * * @param string $name Name of the property (allows "stream" only). * * @return StreamInterface */ public function __get($name) { if ($name == 'stream') { $this->stream = $this->createStream(); return $this->stream; } throw new \UnexpectedValueException("$name not found on class"); } public function __toString() { try { if ($this->isSeekable()) { $this->seek(0); } return $this->getContents(); } catch (\Exception $e) { // Really, PHP? https://bugs.php.net/bug.php?id=53648 trigger_error('StreamDecorator::__toString exception: ' . (string) $e, E_USER_ERROR); return ''; } } public function getContents() { return copy_to_string($this); } /** * Allow decorators to implement custom methods * * @param string $method Missing method name * @param array $args Method arguments * * @return mixed */ public function __call($method, array $args) { $result = call_user_func_array([$this->stream, $method], $args); // Always return the wrapped object if the result is a return $this return $result === $this->stream ? $this : $result; } public function close() { $this->stream->close(); } public function getMetadata($key = null) { return $this->stream->getMetadata($key); } public function detach() { return $this->stream->detach(); } public function getSize() { return $this->stream->getSize(); } public function eof() { return $this->stream->eof(); } public function tell() { return $this->stream->tell(); } public function isReadable() { return $this->stream->isReadable(); } public function isWritable() { return $this->stream->isWritable(); } public function isSeekable() { return $this->stream->isSeekable(); } public function rewind() { $this->seek(0); } public function seek($offset, $whence = SEEK_SET) { $this->stream->seek($offset, $whence); } public function read($length) { return $this->stream->read($length); } public function write($string) { return $this->stream->write($string); } /** * Implement in subclasses to dynamically create streams when requested. * * @return StreamInterface * @throws \BadMethodCallException */ protected function createStream() { throw new \BadMethodCallException('Not implemented'); } }
Name | Type | Size | Permission | Actions |
---|---|---|---|---|
AppendStream.php | File | 5.59 KB | 0644 |
|
BufferStream.php | File | 2.97 KB | 0644 |
|
CachingStream.php | File | 4.15 KB | 0644 |
|
DroppingStream.php | File | 1.05 KB | 0644 |
|
FnStream.php | File | 3.84 KB | 0644 |
|
InflateStream.php | File | 1.78 KB | 0644 |
|
LazyOpenStream.php | File | 880 B | 0644 |
|
LimitStream.php | File | 4.11 KB | 0644 |
|
MessageTrait.php | File | 4.47 KB | 0644 |
|
MultipartStream.php | File | 4.58 KB | 0644 |
|
NoSeekStream.php | File | 424 B | 0644 |
|
PumpStream.php | File | 3.94 KB | 0644 |
|
Request.php | File | 3.35 KB | 0644 |
|
Response.php | File | 4.13 KB | 0644 |
|
Rfc7230.php | File | 684 B | 0644 |
|
ServerRequest.php | File | 9.57 KB | 0644 |
|
Stream.php | File | 7.04 KB | 0644 |
|
StreamDecoratorTrait.php | File | 3.2 KB | 0644 |
|
StreamWrapper.php | File | 3.67 KB | 0644 |
|
UploadedFile.php | File | 7.37 KB | 0644 |
|
Uri.php | File | 20.3 KB | 0644 |
|
UriNormalizer.php | File | 8.12 KB | 0644 |
|
UriResolver.php | File | 8.57 KB | 0644 |
|
functions.php | File | 26.03 KB | 0644 |
|
functions_include.php | File | 156 B | 0644 |
|