Forward compatibility with Stream v0.5 semantics

Author: clue

composer.json

@@ -12,7 +12,7 @@
     ],
     "require": {
         "php": ">=5.3",
-        "react/stream": "~0.4.3",
+        "react/stream": "^0.5 || ^0.4.3",
         "clue/stream-filter": "~1.3"
     },
     "require-dev": {

src/TransformStream.php

@@ -20,7 +20,7 @@ class TransformStream extends EventEmitter implements DuplexStreamInterface
     public function write($data)
     {
         if (!$this->writable || $data === '') {
-            return;
+            return false;
         }
 
         try {
@@ -57,7 +57,7 @@ public function close()
         $this->readable = false;
         $this->writable = false;
 
-        $this->emit('close', array($this));
+        $this->emit('close');
     }
 
     public function isReadable()
@@ -98,10 +98,10 @@ public function pipe(WritableStreamInterface $dest, array $options = array())
      */
     protected function forwardData($data)
     {
-        if (!$this->readable && $data !== '') {
+        if (!$this->readable) {
             return;
         }
-        $this->emit('data', array($data, $this));
+        $this->emit('data', array($data));
     }
 
     /**
@@ -121,7 +121,7 @@ protected function forwardEnd()
         $this->readable = false;
         $this->writable = false;
 
-        $this->emit('end', array($this));
+        $this->emit('end');
         $this->close();
     }
 
@@ -143,7 +143,7 @@ protected function forwardError(Exception $error)
         $this->readable = false;
         $this->writable = false;
 
-        $this->emit('error', array($error, $this));
+        $this->emit('error', array($error));
         $this->close();
     }