Update Channel.php

Author: VennDev

src/vennv/vapm/Channel.php

@@ -43,7 +43,14 @@ public function send($message): Generator;
      *
      * This function is used to receive a message from the channel.
      */
-    public function receive(): Generator;
+    public function receiveGen(): Generator;
+
+    /**
+     * @return mixed
+     *
+     * This function is used to receive a message from the channel.
+     */
+    public function receive(): mixed;
 
     /**
      * @return bool
@@ -89,7 +96,7 @@ public function send($message): Generator
         $this->locked = false;
     }
 
-    public function receive(): Generator
+    public function receiveGen(): Generator
     {
         $this->exceptionIfClosed();
         while ($this->locked) {
@@ -102,6 +109,18 @@ public function receive(): Generator
         return yield $message;
     }
 
+    public function receive(): mixed
+    {
+        $this->exceptionIfClosed();
+        while ($this->locked) {
+            CoroutineGen::run();
+        }
+        $this->locked = true;
+        $message = array_shift($this->queue);
+        $this->locked = false;
+        return $message;
+    }
+
     public function isEmpty(): bool
     {
         return empty($this->queue);
@@ -122,4 +141,4 @@ private function exceptionIfClosed(): void
         if ($this->closed) throw new RuntimeException('Channel is closed');
     }
 
-}
+}