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