|
@@ 583-585 (lines=3) @@
|
| 580 |
|
$this->result = $this->ptr; |
| 581 |
|
if (!$this->subscribed) { |
| 582 |
|
$this->resultType = !$this->resultTypeStack->isEmpty() ? $this->resultTypeStack->shift() : static::RESULT_TYPE_DEFAULT; |
| 583 |
|
if ($this->resultType === static::RESULT_TYPE_ARGSVALS) { |
| 584 |
|
$this->args = !$this->argsStack->isEmpty() ? $this->argsStack->shift() : []; |
| 585 |
|
} |
| 586 |
|
$this->onResponse->executeOne($this); |
| 587 |
|
goto clean; |
| 588 |
|
} elseif ($this->result[0] === 'message') { |
|
@@ 594-596 (lines=3) @@
|
| 591 |
|
$t = &$this->psubscribeCb; |
| 592 |
|
} else { |
| 593 |
|
$this->resultType = !$this->resultTypeStack->isEmpty() ? $this->resultTypeStack->shift() : static::RESULT_TYPE_DEFAULT; |
| 594 |
|
if ($this->resultType === static::RESULT_TYPE_ARGSVALS) { |
| 595 |
|
$this->args = !$this->argsStack->isEmpty() ? $this->argsStack->shift() : []; |
| 596 |
|
} |
| 597 |
|
$this->onResponse->executeOne($this); |
| 598 |
|
goto clean; |
| 599 |
|
} |