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 }
|