kriswallsmith#40: Do not lose fork messages after receive

src/Fork.php

@@ -29,13 +29,17 @@ class Fork implements DeferredInterface
     private $status;
     private $message;
 
+    /** @var array<int,mixed> $messages */
+    private $messages;
+
     public function __construct($pid, SharedMemory $shm, $debug = false)
     {
         $this->defer = new Deferred();
         $this->pid = $pid;
         $this->shm = $shm;
         $this->debug = $debug;
         $this->name = '<anonymous>';
+        $this->messages = [];
     }
 
     /**
@@ -94,19 +98,17 @@ public function processWaitStatus($status)
         }
     }
 
-    public function receive()
+    public function receive(): array
     {
-        $messages = [];
-
         foreach ($this->shm->receive() as $message) {
             if ($message instanceof ExitMessage) {
                 $this->message = $message;
             } else {
-                $messages[] = $message;
+                $this->messages[] = $message;
             }
         }
 
-        return $messages;
+        return $this->messages;
     }
 
     public function kill($signal = SIGINT)
@@ -139,6 +141,11 @@ public function getError()
         }
     }
 
+    public function getMessages(): array
+    {
+        return $this->messages;
+    }
+
     public function isSuccessful()
     {
         return 0 === $this->getExitStatus();