|
@@ 608-610 (lines=3) @@
|
| 605 |
|
$this->result = $this->ptr; |
| 606 |
|
if (!$this->subscribed) { |
| 607 |
|
$this->resultType = !$this->resultTypeStack->isEmpty() ? $this->resultTypeStack->shift() : static::RESULT_TYPE_DEFAULT; |
| 608 |
|
if ($this->resultType === static::RESULT_TYPE_ARGSVALS) { |
| 609 |
|
$this->args = !$this->argsStack->isEmpty() ? $this->argsStack->shift() : []; |
| 610 |
|
} |
| 611 |
|
$this->onResponse->executeOne($this); |
| 612 |
|
goto clean; |
| 613 |
|
} elseif ($this->result[0] === 'message') { |
|
@@ 619-621 (lines=3) @@
|
| 616 |
|
$t = &$this->psubscribeCb; |
| 617 |
|
} else { |
| 618 |
|
$this->resultType = !$this->resultTypeStack->isEmpty() ? $this->resultTypeStack->shift() : static::RESULT_TYPE_DEFAULT; |
| 619 |
|
if ($this->resultType === static::RESULT_TYPE_ARGSVALS) { |
| 620 |
|
$this->args = !$this->argsStack->isEmpty() ? $this->argsStack->shift() : []; |
| 621 |
|
} |
| 622 |
|
$this->onResponse->executeOne($this); |
| 623 |
|
goto clean; |
| 624 |
|
} |