[RFC] Remove removeStream() method, use removeReadStream/removeWriteStream instead

README.md

@@ -41,7 +41,7 @@ $loop->addReadStream($server, function ($server) use ($loop) {
         $written = fwrite($conn, $data);
         if ($written === strlen($data)) {
             fclose($conn);
-            $loop->removeStream($conn);
+            $loop->removeWriteStream($conn);
         } else {
             $data = substr($data, $written);
         }
@@ -394,14 +394,6 @@ remove the write event listener for the given stream.
 Removing a stream from the loop that has already been removed or trying
 to remove a stream that was never added or is invalid has no effect.
 
-### removeStream()
-
-The `removeStream(resource $stream): void` method can be used to
-remove all listeners for the given stream.
-
-Removing a stream from the loop that has already been removed or trying
-to remove a stream that was never added or is invalid has no effect.
-
 ## Install
 
 The recommended way to install this library is [through Composer](http://getcomposer.org).

examples/21-http-server.php

@@ -14,7 +14,7 @@
         $written = fwrite($conn, $data);
         if ($written === strlen($data)) {
             fclose($conn);
-            $loop->removeStream($conn);
+            $loop->removeWriteStream($conn);
         } else {
             $data = substr($data, $written);
         }

src/ExtEventLoop.php

@@ -88,10 +88,7 @@ public function removeWriteStream($stream)
         }
     }
 
-    /**
-     * {@inheritdoc}
-     */
-    public function removeStream($stream)
+    private function removeStream($stream)
     {
         $key = (int) $stream;
 

src/LibEvLoop.php

@@ -94,15 +94,6 @@ public function removeWriteStream($stream)
         }
     }
 
-    /**
-     * {@inheritdoc}
-     */
-    public function removeStream($stream)
-    {
-        $this->removeReadStream($stream);
-        $this->removeWriteStream($stream);
-    }
-
     /**
      * {@inheritdoc}
      */

src/LibEventLoop.php

@@ -89,10 +89,7 @@ public function removeWriteStream($stream)
         }
     }
 
-    /**
-     * {@inheritdoc}
-     */
-    public function removeStream($stream)
+    private function removeStream($stream)
     {
         $key = (int) $stream;
 

src/LoopInterface.php

@@ -120,16 +120,6 @@ public function removeReadStream($stream);
      */
     public function removeWriteStream($stream);
 
-    /**
-     * Remove all listeners for the given stream.
-     *
-     * Removing a stream from the loop that has already been removed or trying
-     * to remove a stream that was never added or is invalid has no effect.
-     *
-     * @param resource $stream The PHP stream resource.
-     */
-    public function removeStream($stream);
-
     /**
      * Enqueue a callback to be invoked once after the given interval.
      *

src/StreamSelectLoop.php

@@ -80,15 +80,6 @@ public function removeWriteStream($stream)
         );
     }
 
-    /**
-     * {@inheritdoc}
-     */
-    public function removeStream($stream)
-    {
-        $this->removeReadStream($stream);
-        $this->removeWriteStream($stream);
-    }
-
     /**
      * {@inheritdoc}
      */

tests/AbstractLoopTest.php

@@ -126,18 +126,6 @@ public function testRemoveWriteStreamAfterWriting()
         $this->tickLoop($this->loop);
     }
 
-    public function testRemoveStreamInstantly()
-    {
-        list ($input, $output) = $this->createSocketPair();
-
-        $this->loop->addReadStream($input, $this->expectCallableNever());
-        $this->loop->addWriteStream($input, $this->expectCallableNever());
-        $this->loop->removeStream($input);
-
-        fwrite($output, "bar\n");
-        $this->tickLoop($this->loop);
-    }
-
     public function testRemoveStreamForReadOnly()
     {
         list ($input, $output) = $this->createSocketPair();
@@ -163,30 +151,13 @@ public function testRemoveStreamForWriteOnly()
         $this->tickLoop($this->loop);
     }
 
-    public function testRemoveStream()
-    {
-        list ($input, $output) = $this->createSocketPair();
-
-        $this->loop->addReadStream($input, $this->expectCallableOnce());
-        $this->loop->addWriteStream($input, $this->expectCallableOnce());
-
-        fwrite($output, "bar\n");
-        $this->tickLoop($this->loop);
-
-        $this->loop->removeStream($input);
-
-        fwrite($output, "bar\n");
-        $this->tickLoop($this->loop);
-    }
-
     public function testRemoveInvalid()
     {
         list ($stream) = $this->createSocketPair();
 
         // remove a valid stream from the event loop that was never added in the first place
         $this->loop->removeReadStream($stream);
         $this->loop->removeWriteStream($stream);
-        $this->loop->removeStream($stream);
     }
 
     /** @test */
@@ -202,7 +173,7 @@ public function runShouldReturnWhenNoMoreFds()
 
         $loop = $this->loop;
         $this->loop->addReadStream($input, function ($stream) use ($loop) {
-            $loop->removeStream($stream);
+            $loop->removeReadStream($stream);
         });
 
         fwrite($output, "foo\n");
@@ -366,7 +337,7 @@ public function testRunWaitsForFutureTickEvents()
         $this->loop->addWriteStream(
             $stream,
             function () use ($stream) {
-                $this->loop->removeStream($stream);
+                $this->loop->removeWriteStream($stream);
                 $this->loop->futureTick(
                     function () {
                         echo 'future-tick' . PHP_EOL;