| @@ 179-192 (lines=14) @@ | ||
| 176 | * | |
| 177 | * @return string | |
| 178 | */ | |
| 179 | public function readLine($sequence) | |
| 180 |     { | |
| 181 |         if (isset($this->_out) && !feof($this->_out)) { | |
| 182 | $line = fgets($this->_out); | |
| 183 |             if (!$line) { | |
| 184 | $metas = stream_get_meta_data($this->_out); | |
| 185 |                 if ($metas['timed_out']) { | |
| 186 |                     throw new Swift_IoException('Connection to ' . $this->_getReadConnectionDescription() . ' Timed Out'); | |
| 187 | } | |
| 188 | } | |
| 189 | ||
| 190 | return $line; | |
| 191 | } | |
| 192 | } | |
| 193 | ||
| 194 | /** | |
| 195 | * Reads $length bytes from the stream into a string and moves the pointer | |
| @@ 207-222 (lines=16) @@ | ||
| 204 | * | |
| 205 | * @return string|null | |
| 206 | */ | |
| 207 | public function read($length) | |
| 208 |     { | |
| 209 |         if (isset($this->_out) && !feof($this->_out)) { | |
| 210 | $ret = fread($this->_out, $length); | |
| 211 |             if (!$ret) { | |
| 212 | $metas = stream_get_meta_data($this->_out); | |
| 213 |                 if ($metas['timed_out']) { | |
| 214 | throw new Swift_IoException( | |
| 215 | 'Connection to ' . $this->_getReadConnectionDescription() . ' Timed Out' | |
| 216 | ); | |
| 217 | } | |
| 218 | } | |
| 219 | ||
| 220 | return $ret; | |
| 221 | } | |
| 222 | } | |
| 223 | ||
| 224 | /** Not implemented */ | |
| 225 | public function setReadPointer($byteOffset) | |