@@ 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 | } |