Fix LibEvLoop to ignore double IO streams

kelunik · kelunik · commit b2acd81a2bd1 · 2017-03-25T13:59:58.000+01:00
diff --git a/src/LibEvLoop.php b/src/LibEvLoop.php
@@ -38,6 +38,10 @@ public function __construct()
      */
     public function addReadStream($stream, callable $listener)
     {
+        if (isset($this->readEvents[(int) $stream])) {
+            return;
+        }
+
         $callback = function () use ($stream, $listener) {
             call_user_func($listener, $stream, $this);
         };
@@ -53,6 +57,10 @@ public function addReadStream($stream, callable $listener)
      */
     public function addWriteStream($stream, callable $listener)
     {
+        if (isset($this->writeEvents[(int) $stream])) {
+            return;
+        }
+
         $callback = function () use ($stream, $listener) {
             call_user_func($listener, $stream, $this);
         };
