@@ 590-592 (lines=3) @@ | ||
587 | $this->result = $this->ptr; |
|
588 | if (!$this->subscribed) { |
|
589 | $this->resultType = !$this->resultTypeStack->isEmpty() ? $this->resultTypeStack->shift() : static::RESULT_TYPE_DEFAULT; |
|
590 | if ($this->resultType === static::RESULT_TYPE_ARGSVALS) { |
|
591 | $this->args = !$this->argsStack->isEmpty() ? $this->argsStack->shift() : []; |
|
592 | } |
|
593 | $this->onResponse->executeOne($this); |
|
594 | goto clean; |
|
595 | } elseif ($this->result[0] === 'message') { |
|
@@ 601-603 (lines=3) @@ | ||
598 | $t = &$this->psubscribeCb; |
|
599 | } else { |
|
600 | $this->resultType = !$this->resultTypeStack->isEmpty() ? $this->resultTypeStack->shift() : static::RESULT_TYPE_DEFAULT; |
|
601 | if ($this->resultType === static::RESULT_TYPE_ARGSVALS) { |
|
602 | $this->args = !$this->argsStack->isEmpty() ? $this->argsStack->shift() : []; |
|
603 | } |
|
604 | $this->onResponse->executeOne($this); |
|
605 | goto clean; |
|
606 | } |