skip ping on message fetch

basis-company · Mar 11, 2024 · 762c0b6 · 762c0b6
1 parent cb86625
commit 762c0b6
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/Client.php b/src/Client.php
@@ -239,15 +239,15 @@ public function process(null|int|float $timeout = 0, bool $reply = true, bool $c
             try {
                 $line = $this->readLine(1024, "\r\n", $checkTimeout);
 
-                if ($line && ($this->ping || trim($line) != 'PONG')) {
+                if ($line && ($this->ping || trim($line) != 'PONG') && ($this->pong || trim($line) != 'PING')) {
                     break;
                 }
                 if ($line === false && $ping < time()) {
                     try {
                         $this->send(new Ping([]));
                         $line = $this->readLine(1024, "\r\n");
                         $ping = time() + $this->configuration->pingInterval;
-                        if ($line && ($this->ping || trim($line) != 'PONG')) {
+                        if ($line && ($this->ping || trim($line) != 'PONG') && ($this->pong || trim($line) != 'PING')) {
                             break;
                         }
                     } catch (Throwable $e) {