Make ThroughStream extend ReadableStream (thanks @elazar)

Author: igorw

ThroughStream.php

@@ -4,9 +4,8 @@
 
 use Evenement\EventEmitter;
 
-class ThroughStream extends EventEmitter implements ReadableStreamInterface, WritableStreamInterface
+class ThroughStream extends ReadableStream implements WritableStreamInterface
 {
-    private $closed = false;
     private $pipeSource;
 
     public function __construct()
@@ -38,11 +37,6 @@ public function end($data = null)
         $this->close();
     }
 
-    public function isReadable()
-    {
-        return !$this->closed;
-    }
-
     public function isWritable()
     {
         return !$this->closed;
@@ -68,18 +62,7 @@ public function close()
             return;
         }
 
-        $this->closed = true;
+        parent::close();
         $this->pipeSource = null;
-
-        $this->emit('end');
-        $this->emit('close');
-        $this->removeAllListeners();
-    }
-
-    public function pipe(WritableStreamInterface $dest, array $options = array())
-    {
-        Util::pipe($this, $dest, $options);
-
-        return $dest;
     }
 }