[QUESTION] 关于协程客户端 about mqtt HOT 6 CLOSED

\Hyperf\Utils\Coroutine::create(function() use($timeSincePing) {
    try {
        $client = $this->client();

        while($this->running){
            $buffer = $client->recv();

            if ($buffer && $buffer !== true) {
                $timeSincePing = time();

                $this->onMessage($buffer);
            }

            if ($timeSincePing <= (time() - $client->getConfig()->getKeepAlive())) {
                $buffer = $client->ping();
                if ($buffer) {
                    $this->write('ping success');
                    $timeSincePing = time();
                } else {
                    $client->close();
                    break;
                }
            }

        }

    } catch (\Throwable $th) {
        $this->write('recv coroutine has error: ' . $th->getMessage());
    }
    
});