This commit is contained in:
2021-03-29 18:45:05 +08:00
parent 9f31902379
commit a289c16422
+3 -5
View File
@@ -52,12 +52,10 @@ class Client extends Component
if ($isSend === false) { if ($isSend === false) {
return $this->addError($this->client->errMsg . '(' . $this->client->errCode . ')'); return $this->addError($this->client->errMsg . '(' . $this->client->errCode . ')');
} }
\Swoole\Coroutine\defer(function () {
$this->recover();
});
if (is_bool($unpack = Json::decode($this->client->recv()))) { if (is_bool($unpack = Json::decode($this->client->recv()))) {
return $this->addError('Service return data format error(500)'); $unpack = $this->addError('Service return data format error(500)');
} }
$this->clientRecover();
return $unpack; return $unpack;
} }
@@ -68,7 +66,7 @@ class Client extends Component
* @throws NotFindClassException * @throws NotFindClassException
* @throws Exception * @throws Exception
*/ */
public function recover(): static public function clientRecover(): static
{ {
/** @var Channel $channel */ /** @var Channel $channel */
$channel = Snowflake::app()->get('channel'); $channel = Snowflake::app()->get('channel');