Typehint against Stream (fixes #5)

Fixes compatibility with react/stream:0.4 which removed the
StreamInterface.

Author: clue

src/Client.php

@@ -5,7 +5,7 @@
 use Clue\React\Ami\Protocol\Event;
 use Clue\React\Ami\Protocol\Action;
 use Evenement\EventEmitter;
-use React\Stream\StreamInterface;
+use React\Stream\Stream;
 use Clue\React\Ami\Protocol\Parser;
 use React\Promise\Deferred;
 use Exception;
@@ -20,7 +20,7 @@ class Client extends EventEmitter
     private $pending = array();
     private $ending = false;
 
-    public function __construct(StreamInterface $stream, Parser $parser = null)
+    public function __construct(Stream $stream, Parser $parser = null)
     {
         if ($parser === null) {
             $parser = new Parser();

tests/ClientTest.php

@@ -3,13 +3,13 @@
 use React\Stream\Stream;
 use Clue\React\Ami\Protocol\Parser;
 use Clue\React\Ami\Client;
-use React\Stream\ThroughStream;
+use React\EventLoop\Factory;
 
 class ClientTest extends TestCase
 {
     public function testClosingStreamClosesClient()
     {
-        $stream = new ThroughStream();
+        $stream = $this->createStreamMock();
 
         $client = new Client($stream);
 
@@ -21,7 +21,7 @@ public function testClosingStreamClosesClient()
 
     public function testParserExceptionForwardsErrorAndClosesClient()
     {
-        $stream = new ThroughStream();
+        $stream = $this->createStreamMock();
         $parser = new Parser();
 
         $client = new Client($stream, $parser);
@@ -31,4 +31,9 @@ public function testParserExceptionForwardsErrorAndClosesClient()
 
         $stream->emit('data', array("invalid chunk\r\n\r\ninvalid chunk\r\n\r\n"));
     }
+
+    private function createStreamMock()
+    {
+        return new Stream(fopen('php://memory', 'r+'), $this->getMock('React\EventLoop\LoopInterface'));
+    }
 }