| @@ 453-462 (lines=10) @@ | ||
| 450 | return; |
|
| 451 | } |
|
| 452 | ||
| 453 | foreach ($read as $stream) |
|
| 454 | { |
|
| 455 | $key = (int) $stream; |
|
| 456 | ||
| 457 | if (isset($this->readListeners[$key])) |
|
| 458 | { |
|
| 459 | $callable = $this->readListeners[$key]; |
|
| 460 | $callable($stream, $this); |
|
| 461 | } |
|
| 462 | } |
|
| 463 | ||
| 464 | foreach ($write as $stream) |
|
| 465 | { |
|
| @@ 464-473 (lines=10) @@ | ||
| 461 | } |
|
| 462 | } |
|
| 463 | ||
| 464 | foreach ($write as $stream) |
|
| 465 | { |
|
| 466 | $key = (int) $stream; |
|
| 467 | ||
| 468 | if (isset($this->writeListeners[$key])) |
|
| 469 | { |
|
| 470 | $callable = $this->writeListeners[$key]; |
|
| 471 | $callable($stream, $this); |
|
| 472 | } |
|
| 473 | } |
|
| 474 | } |
|
| 475 | ||
| 476 | /** |
|