|
@@ 617-619 (lines=3) @@
|
| 614 |
|
$this->result = $this->ptr; |
| 615 |
|
if (!$this->subscribed) { |
| 616 |
|
$this->resultType = !$this->resultTypeStack->isEmpty() ? $this->resultTypeStack->shift() : static::RESULT_TYPE_DEFAULT; |
| 617 |
|
if ($this->resultType === static::RESULT_TYPE_ARGSVALS) { |
| 618 |
|
$this->args = !$this->argsStack->isEmpty() ? $this->argsStack->shift() : []; |
| 619 |
|
} |
| 620 |
|
$this->onResponse->executeOne($this); |
| 621 |
|
goto clean; |
| 622 |
|
} elseif ($this->result[0] === 'message') { |
|
@@ 628-630 (lines=3) @@
|
| 625 |
|
$t = &$this->psubscribeCb; |
| 626 |
|
} else { |
| 627 |
|
$this->resultType = !$this->resultTypeStack->isEmpty() ? $this->resultTypeStack->shift() : static::RESULT_TYPE_DEFAULT; |
| 628 |
|
if ($this->resultType === static::RESULT_TYPE_ARGSVALS) { |
| 629 |
|
$this->args = !$this->argsStack->isEmpty() ? $this->argsStack->shift() : []; |
| 630 |
|
} |
| 631 |
|
$this->onResponse->executeOne($this); |
| 632 |
|
goto clean; |
| 633 |
|
} |