Wait a bit before reading the next socket chunk

CHANGELOG.md

@@ -7,6 +7,7 @@ and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.
 
 ## [Unreleased]
 ### Fixed
+- Heavy socket payloads are no longer unreadable in slow environments
 - Fix an issue where the console object can't be set in some environments
 
 ## [1.2.0] - 2018-08-20

src/ProcessSupervisor.php

@@ -39,6 +39,14 @@ class ProcessSupervisor
      */
     protected const SOCKET_HEADER_SIZE = 5;
 
+    /**
+     * A short period to wait before reading the next chunk (in milliseconds), this avoids the next chunk to be read as
+     * an empty string when PuPHPeteer is running on a slow environment.
+     *
+     * @var int
+     */
+    protected const SOCKET_NEXT_CHUNK_DELAY = 1;
+
     /**
      * Options to remove before sending them for the process.
      *
@@ -404,6 +412,11 @@ protected function readNextProcessValue(bool $valueShouldBeLogged = true)
                 $chunk = substr($packet, static::SOCKET_HEADER_SIZE);
 
                 $payload .= $chunk;
+
+                if ($chunksLeft > 0) {
+                    // The next chunk might be an empty string if don't wait a short period on slow environments.
+                    usleep(self::SOCKET_NEXT_CHUNK_DELAY * 1000);
+                }
             } while ($chunksLeft > 0);
         } catch (SocketException $exception) {
             $this->waitForProcessTermination();