kakserpom /
phpdaemon
| @@ 434-441 (lines=8) @@ | ||
| 431 | return; |
|
| 432 | } |
|
| 433 | CallbackWrapper::removeFromArray($this->subscribeCb[$chan], $cb); |
|
| 434 | if (sizeof($this->subscribeCb[$chan]) === 0) { |
|
| 435 | $channels[] = $chan; |
|
| 436 | unset($this->subscribeCb[$chan]); |
|
| 437 | } else { |
|
| 438 | if ($opcb !== null) { |
|
| 439 | call_user_func($opcb, $this); |
|
| 440 | } |
|
| 441 | } |
|
| 442 | } |
|
| 443 | } |
|
| 444 | if (sizeof($channels)) { |
|
| @@ 482-489 (lines=8) @@ | ||
| 479 | } |
|
| 480 | foreach ($arg as $chan) { |
|
| 481 | CallbackWrapper::removeFromArray($this->psubscribeCb[$chan], $cb); |
|
| 482 | if (sizeof($this->psubscribeCb[$chan]) === 0) { |
|
| 483 | $channels[] = $chan; |
|
| 484 | unset($this->psubscribeCb[$chan]); |
|
| 485 | } else { |
|
| 486 | if ($opcb !== null) { |
|
| 487 | call_user_func($opcb, $this); |
|
| 488 | } |
|
| 489 | } |
|
| 490 | } |
|
| 491 | } |
|
| 492 | if (sizeof($channels)) { |
|
