Merge pull request #14 from clue-labs/close

Remove event listeners once closed

Author: clue

src/TransformStream.php

@@ -58,6 +58,7 @@ public function close()
         $this->writable = false;
 
         $this->emit('close');
+        $this->removeAllListeners();
     }
 
     public function isReadable()

tests/TransformStreamTest.php

@@ -53,6 +53,18 @@ public function testDoesNotEmitIfAlreadyEnded(TransformStream $stream)
         $stream->close();
     }
 
+    public function testCloseRemovesListeners()
+    {
+        $stream = new TransformStream();
+        $this->assertCount(0, $stream->listeners('close'));
+
+        $stream->on('close', $this->expectCallableOnce());
+        $this->assertCount(1, $stream->listeners('close'));
+
+        $stream->close();
+        $this->assertCount(0, $stream->listeners('close'));
+    }
+
     public function testCloseOnlyEmitsCloses()
     {
         $stream = new TransformStream();