kakserpom /
phpdaemon
| @@ 421-428 (lines=8) @@ | ||
| 418 | return; |
|
| 419 | } |
|
| 420 | CallbackWrapper::removeFromArray($this->subscribeCb[$chan], $cb); |
|
| 421 | if (sizeof($this->subscribeCb[$chan]) === 0) { |
|
| 422 | $channels[] = $chan; |
|
| 423 | unset($this->subscribeCb[$chan]); |
|
| 424 | } else { |
|
| 425 | if ($opcb !== null) { |
|
| 426 | call_user_func($opcb, $this); |
|
| 427 | } |
|
| 428 | } |
|
| 429 | } |
|
| 430 | } |
|
| 431 | if (sizeof($channels)) { |
|
| @@ 469-476 (lines=8) @@ | ||
| 466 | } |
|
| 467 | foreach ($arg as $chan) { |
|
| 468 | CallbackWrapper::removeFromArray($this->psubscribeCb[$chan], $cb); |
|
| 469 | if (sizeof($this->psubscribeCb[$chan]) === 0) { |
|
| 470 | $channels[] = $chan; |
|
| 471 | unset($this->psubscribeCb[$chan]); |
|
| 472 | } else { |
|
| 473 | if ($opcb !== null) { |
|
| 474 | call_user_func($opcb, $this); |
|
| 475 | } |
|
| 476 | } |
|
| 477 | } |
|
| 478 | } |
|
| 479 | if (sizeof($channels)) { |
|
