Remove event listeners from CompositeStream once closed

Author: clue

src/CompositeStream.php

@@ -6,9 +6,9 @@
 
 final class CompositeStream extends EventEmitter implements DuplexStreamInterface
 {
-    protected $readable;
-    protected $writable;
-    protected $closed = false;
+    private $readable;
+    private $writable;
+    private $closed = false;
 
     public function __construct(ReadableStreamInterface $readable, WritableStreamInterface $writable)
     {
@@ -77,5 +77,6 @@ public function close()
         $this->writable->close();
 
         $this->emit('close');
+        $this->removeAllListeners();
     }
 }

tests/CompositeStreamTest.php

@@ -188,6 +188,25 @@ public function itShouldForwardCloseOnlyOnce()
         $writable->close();
     }
 
+    /** @test */
+    public function itShouldForwardCloseAndRemoveAllListeners()
+    {
+        $in = new ThroughStream();
+
+        $composite = new CompositeStream($in, $in);
+        $composite->on('close', $this->expectCallableOnce());
+
+        $this->assertTrue($composite->isReadable());
+        $this->assertTrue($composite->isWritable());
+        $this->assertCount(1, $composite->listeners('close'));
+
+        $composite->close();
+
+        $this->assertFalse($composite->isReadable());
+        $this->assertFalse($composite->isWritable());
+        $this->assertCount(0, $composite->listeners('close'));
+    }
+
     /** @test */
     public function itShouldReceiveForwardedEvents()
     {