| @@ 278-287 (lines=10) @@ | ||
| 275 | return; |
|
| 276 | } |
|
| 277 | ||
| 278 | if ($ret !== '') |
|
| 279 | { |
|
| 280 | $this->emit('data', [ $this, $ret ]); |
|
| 281 | ||
| 282 | if (strlen($ret) < $length) |
|
| 283 | { |
|
| 284 | $this->reading = false; |
|
| 285 | $this->emit('end', [ $this ]); |
|
| 286 | } |
|
| 287 | } |
|
| 288 | } |
|
| 289 | catch (Error $ex) |
|
| 290 | { |
|
| @@ 335-343 (lines=9) @@ | ||
| 332 | new ReadException('Cannot read stream.') |
|
| 333 | ); |
|
| 334 | } |
|
| 335 | else if ($ret !== '') |
|
| 336 | { |
|
| 337 | $this->emit('data', [ $this, $ret ]); |
|
| 338 | ||
| 339 | if (strlen($ret) < $length) |
|
| 340 | { |
|
| 341 | $this->emit('end', [ $this ]); |
|
| 342 | } |
|
| 343 | } |
|
| 344 | ||
| 345 | return $ret; |
|
| 346 | } |
|