maikgreubel /
phpgenerics
| @@ 91-118 (lines=28) @@ | ||
| 88 | * {@inheritdoc} |
|
| 89 | * @see \Generics\Streams\Stream::ready() |
|
| 90 | */ |
|
| 91 | public function ready(): bool |
|
| 92 | { |
|
| 93 | if (! is_resource($this->handle)) { |
|
| 94 | return false; |
|
| 95 | } |
|
| 96 | ||
| 97 | $read = array( |
|
| 98 | $this->handle |
|
| 99 | ); |
|
| 100 | $write = null; |
|
| 101 | $except = null; |
|
| 102 | ||
| 103 | $num = @stream_select($read, $write, $except, 0); |
|
| 104 | ||
| 105 | if ($num === false) { |
|
| 106 | throw new SocketException("Could not determine the stream client status"); |
|
| 107 | } |
|
| 108 | ||
| 109 | if ($num < 1) { |
|
| 110 | return false; |
|
| 111 | } |
|
| 112 | ||
| 113 | if (! in_array($this->handle, $read)) { |
|
| 114 | return false; |
|
| 115 | } |
|
| 116 | ||
| 117 | return true; |
|
| 118 | } |
|
| 119 | ||
| 120 | /** |
|
| 121 | * |
|
| @@ 194-221 (lines=28) @@ | ||
| 191 | * {@inheritdoc} |
|
| 192 | * @see \Generics\Streams\OutputStream::isWriteable() |
|
| 193 | */ |
|
| 194 | public function isWriteable(): bool |
|
| 195 | { |
|
| 196 | if (! is_resource($this->handle)) { |
|
| 197 | return false; |
|
| 198 | } |
|
| 199 | ||
| 200 | $read = null; |
|
| 201 | $write = array( |
|
| 202 | $this->handle |
|
| 203 | ); |
|
| 204 | $except = null; |
|
| 205 | ||
| 206 | $num = @stream_select($read, $write, $except, 0, 0); |
|
| 207 | ||
| 208 | if ($num === false) { |
|
| 209 | throw new SocketException("Could not determine the stream client status"); |
|
| 210 | } |
|
| 211 | ||
| 212 | if ($num < 1) { |
|
| 213 | return false; |
|
| 214 | } |
|
| 215 | ||
| 216 | if (! in_array($this->handle, $write)) { |
|
| 217 | return false; |
|
| 218 | } |
|
| 219 | ||
| 220 | return true; |
|
| 221 | } |
|
| 222 | ||
| 223 | private function open() |
|
| 224 | { |
|
