Fixed #40 - unpack not having enough input

amphp · Sep 21, 2017 · a88b51f · a88b51f
1 parent c784784
commit a88b51f
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/lib/Processor.php b/lib/Processor.php
@@ -987,8 +987,8 @@ private function parseCompression() {
         $buf = "";
 
         while (true) {
-            while (\strlen($buf) < 4) {
-                $buf .= (yield $inflated);
+            while (\strlen($buf) < 7) {
+                $buf .= yield $inflated;
                 $inflated = "";
             }
 
@@ -1000,7 +1000,7 @@ private function parseCompression() {
 
             if ($size > 0) {
                 while (\strlen($buf) < $size) {
-                    $buf .= (yield $inflated);
+                    $buf .= yield $inflated;
                     $inflated = "";
                 }
 
@@ -1028,7 +1028,7 @@ private function parseMysql(): \Generator {
 
             do {
                 while (\strlen($buf) < 4) {
-                    $buf .= (yield $parsed);
+                    $buf .= yield $parsed;
                     $parsed = [];
                 }
 
@@ -1037,7 +1037,7 @@ private function parseMysql(): \Generator {
                 $buf = substr($buf, 4);
 
                 while (\strlen($buf) < ($len & 0xffffff)) {
-                    $buf .= (yield $parsed);
+                    $buf .= yield $parsed;
                     $parsed = [];
                 }