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