read data using stream_select fetch data using stream_get_line

Author: nekufa

src/Connection.php

@@ -63,6 +63,24 @@ public function getMessage(null|int|float $timeout = 0): ?Message
             if (!is_resource($this->socket) || feof($this->socket)) {
                 throw new LogicException('supplied resource is not a valid stream resource');
             }
+
+            $remainingTimeout = $max - microtime(true);
+            if ($remainingTimeout <= 0) {
+                break;
+            }
+
+            $read = [$this->socket];
+            $write = null;
+            $except = null;
+            $seconds = (int) floor($remainingTimeout);
+            $microseconds = (int) (($remainingTimeout - $seconds) * 1_000_000);
+
+            $result = stream_select($read, $write, $except, $seconds, $microseconds);
+
+            if ($result === false || $result === 0) {
+                break;
+            }
+
             $message = null;
             $line = stream_get_line($this->socket, 1024, "\r\n");
             $now = microtime(true);
@@ -98,9 +116,6 @@ public function getMessage(null|int|float $timeout = 0): ?Message
                     }
                 }
             }
-            if ($now > $max) {
-                break;
-            }
             if ($message && $now < $max) {
                 $this->logger?->debug('sleep', compact('max', 'now'));
                 $this->config->delay($iteration++);