Merge pull request #1 from appwrite-labs/fix-realtime-speed

Fix: realtime chunking speed

Author: Meldiron

src/KubernetesCluster.php

@@ -267,15 +267,24 @@ protected function watchLogsPath(string $path, Closure $callback, array $query =
 
         $data = null;
 
-        while (($data = fgets($sock)) == true) {
-            $call = call_user_func($callback, $data);
-
-            if (! is_null($call)) {
-                fclose($sock);
-
-                unset($data);
-
-                return $call;
+        $chunk = '';
+        while (($data = fgets($sock, 64)) == true) {
+            $chunk .= $data;
+
+            $separator = \strrpos($chunk, "\n");
+            if ($separator !== false) {
+                $extra = \substr($chunk, $separator + \strlen("\n"));
+                $chunk = \substr($chunk, 0, $separator) . "\n";
+
+                $call = call_user_func($callback, $chunk);
+                if (!is_null($call)) {
+                    fclose($sock);
+                    unset($data);
+                    unset($chunk);
+                    return $call;
+                }
+
+                $chunk = $extra;
             }
         }
     }