annotate vendor/zendframework/zend-diactoros/src/CallbackStream.php @ 19:fa3358dc1485 tip

Add ndrum files
author Chris Cannam
date Wed, 28 Aug 2019 13:14:47 +0100
parents c2387f117808
children
rev   line source
Chris@0 1 <?php
Chris@0 2 /**
Chris@0 3 * Zend Framework (http://framework.zend.com/)
Chris@0 4 *
Chris@0 5 * @see http://github.com/zendframework/zend-diactoros for the canonical source repository
Chris@0 6 * @copyright Copyright (c) 2015-2016 Zend Technologies USA Inc. (http://www.zend.com)
Chris@0 7 * @license https://github.com/zendframework/zend-diactoros/blob/master/LICENSE.md New BSD License
Chris@0 8 */
Chris@0 9
Chris@0 10 namespace Zend\Diactoros;
Chris@0 11
Chris@0 12 use InvalidArgumentException;
Chris@16 13 use Psr\Http\Message\StreamInterface;
Chris@0 14 use RuntimeException;
Chris@16 15
Chris@16 16 use function array_key_exists;
Chris@16 17
Chris@16 18 use const SEEK_SET;
Chris@0 19
Chris@0 20 /**
Chris@0 21 * Implementation of PSR HTTP streams
Chris@0 22 */
Chris@0 23 class CallbackStream implements StreamInterface
Chris@0 24 {
Chris@0 25 /**
Chris@0 26 * @var callable|null
Chris@0 27 */
Chris@0 28 protected $callback;
Chris@0 29
Chris@0 30 /**
Chris@0 31 * @param callable $callback
Chris@0 32 * @throws InvalidArgumentException
Chris@0 33 */
Chris@0 34 public function __construct(callable $callback)
Chris@0 35 {
Chris@0 36 $this->attach($callback);
Chris@0 37 }
Chris@0 38
Chris@0 39 /**
Chris@0 40 * {@inheritdoc}
Chris@0 41 */
Chris@0 42 public function __toString()
Chris@0 43 {
Chris@0 44 return $this->getContents();
Chris@0 45 }
Chris@0 46
Chris@0 47 /**
Chris@0 48 * {@inheritdoc}
Chris@0 49 */
Chris@0 50 public function close()
Chris@0 51 {
Chris@0 52 $this->callback = null;
Chris@0 53 }
Chris@0 54
Chris@0 55 /**
Chris@0 56 * {@inheritdoc}
Chris@0 57 */
Chris@0 58 public function detach()
Chris@0 59 {
Chris@0 60 $callback = $this->callback;
Chris@0 61 $this->callback = null;
Chris@0 62 return $callback;
Chris@0 63 }
Chris@0 64
Chris@0 65 /**
Chris@0 66 * Attach a new callback to the instance.
Chris@0 67 *
Chris@0 68 * @param callable $callback
Chris@0 69 * @throws InvalidArgumentException for callable callback
Chris@0 70 */
Chris@0 71 public function attach(callable $callback)
Chris@0 72 {
Chris@0 73 $this->callback = $callback;
Chris@0 74 }
Chris@0 75
Chris@0 76 /**
Chris@0 77 * {@inheritdoc}
Chris@0 78 */
Chris@0 79 public function getSize()
Chris@0 80 {
Chris@0 81 }
Chris@0 82
Chris@0 83 /**
Chris@0 84 * {@inheritdoc}
Chris@0 85 */
Chris@0 86 public function tell()
Chris@0 87 {
Chris@0 88 throw new RuntimeException('Callback streams cannot tell position');
Chris@0 89 }
Chris@0 90
Chris@0 91 /**
Chris@0 92 * {@inheritdoc}
Chris@0 93 */
Chris@0 94 public function eof()
Chris@0 95 {
Chris@0 96 return empty($this->callback);
Chris@0 97 }
Chris@0 98
Chris@0 99 /**
Chris@0 100 * {@inheritdoc}
Chris@0 101 */
Chris@0 102 public function isSeekable()
Chris@0 103 {
Chris@0 104 return false;
Chris@0 105 }
Chris@0 106
Chris@0 107 /**
Chris@0 108 * {@inheritdoc}
Chris@0 109 */
Chris@0 110 public function seek($offset, $whence = SEEK_SET)
Chris@0 111 {
Chris@0 112 throw new RuntimeException('Callback streams cannot seek position');
Chris@0 113 }
Chris@0 114
Chris@0 115 /**
Chris@0 116 * {@inheritdoc}
Chris@0 117 */
Chris@0 118 public function rewind()
Chris@0 119 {
Chris@0 120 throw new RuntimeException('Callback streams cannot rewind position');
Chris@0 121 }
Chris@0 122
Chris@0 123 /**
Chris@0 124 * {@inheritdoc}
Chris@0 125 */
Chris@0 126 public function isWritable()
Chris@0 127 {
Chris@0 128 return false;
Chris@0 129 }
Chris@0 130
Chris@0 131 /**
Chris@0 132 * {@inheritdoc}
Chris@0 133 */
Chris@0 134 public function write($string)
Chris@0 135 {
Chris@0 136 throw new RuntimeException('Callback streams cannot write');
Chris@0 137 }
Chris@0 138
Chris@0 139 /**
Chris@0 140 * {@inheritdoc}
Chris@0 141 */
Chris@0 142 public function isReadable()
Chris@0 143 {
Chris@0 144 return false;
Chris@0 145 }
Chris@0 146
Chris@0 147 /**
Chris@0 148 * {@inheritdoc}
Chris@0 149 */
Chris@0 150 public function read($length)
Chris@0 151 {
Chris@0 152 throw new RuntimeException('Callback streams cannot read');
Chris@0 153 }
Chris@0 154
Chris@0 155 /**
Chris@0 156 * {@inheritdoc}
Chris@0 157 */
Chris@0 158 public function getContents()
Chris@0 159 {
Chris@0 160 $callback = $this->detach();
Chris@0 161 return $callback ? $callback() : '';
Chris@0 162 }
Chris@0 163
Chris@0 164 /**
Chris@0 165 * {@inheritdoc}
Chris@0 166 */
Chris@0 167 public function getMetadata($key = null)
Chris@0 168 {
Chris@0 169 $metadata = [
Chris@0 170 'eof' => $this->eof(),
Chris@0 171 'stream_type' => 'callback',
Chris@0 172 'seekable' => false
Chris@0 173 ];
Chris@0 174
Chris@0 175 if (null === $key) {
Chris@0 176 return $metadata;
Chris@0 177 }
Chris@0 178
Chris@0 179 if (! array_key_exists($key, $metadata)) {
Chris@0 180 return null;
Chris@0 181 }
Chris@0 182
Chris@0 183 return $metadata[$key];
Chris@0 184 }
Chris@0 185 }