Merge pull request #63 from reactphp-parallel/silence-channel-closed-errors-on-proxy-close

Silence channel closed errors on proxy close

Author: WyriHaximus

infection.json.dist

@@ -68,6 +68,16 @@
                 "ReactParallel\\ObjectProxy\\Proxy\\Registry::__construct"
             ]
         },
+        "LogicalOr": {
+            "ignore": [
+                "ReactParallel\\ObjectProxy\\Proxy\\Handler::handleExistence",
+                "ReactParallel\\ObjectProxy\\Proxy\\Handler::countDestruct",
+                "ReactParallel\\ObjectProxy\\Proxy\\Handler::handleDestruct",
+                "ReactParallel\\ObjectProxy\\Proxy\\Handler::handleNotify",
+                "ReactParallel\\ObjectProxy\\Proxy\\Handler::handleCall",
+                "ReactParallel\\ObjectProxy\\Proxy\\Registry::__construct"
+            ]
+        },
         "MethodCallRemoval": {
             "ignore": [
                 "ReactParallel\\ObjectProxy\\Proxy::__destruct",

src/Proxy.php

@@ -5,6 +5,7 @@
 namespace ReactParallel\ObjectProxy;
 
 use parallel\Channel;
+use parallel\Channel\Error\Closed;
 use React\EventLoop\StreamSelectLoop;
 use ReactParallel\EventLoop\EventLoopBridge;
 use ReactParallel\Factory;
@@ -156,11 +157,19 @@ public function close(): void
         $this->closed = TRUE_;
 
         foreach ($this->destruct as $destruct) {
-            $destruct->send('bye');
-            $destruct->close();
+            try {
+                $destruct->send('bye');
+                $destruct->close();
+            } catch (Closed $closed) {
+                // @ignoreException
+            }
         }
 
-        $this->in->close();
+        try {
+            $this->in->close();
+        } catch (Closed $closed) {
+            // @ignoreException
+        }
     }
 
     public function __destruct()