Forward compatibility with upcoming Stream v1.0 through old v0.4

Author: clue

composer.json

@@ -8,7 +8,7 @@
         "guzzlehttp/psr7": "^1.0",
         "react/socket": "^0.7",
         "react/event-loop": "0.4.*",
-        "react/stream": "^0.5|^0.6",
+        "react/stream": "^1.0 || ^0.7 || ^0.6 || ^0.5 || ^0.4.2",
         "react/promise": "~2.2",
         "evenement/evenement": "~2.0"
     },

tests/RequestTest.php

@@ -5,6 +5,7 @@
 use React\HttpClient\Request;
 use React\HttpClient\RequestData;
 use React\Stream\Stream;
+use React\Stream\DuplexResourceStream;
 use React\Promise\RejectedPromise;
 use React\Promise\Deferred;
 use React\Promise\Promise;
@@ -428,7 +429,7 @@ public function pipeShouldPipeDataIntoTheRequestBody()
         $request->setResponseFactory($factory);
 
         $stream = fopen('php://memory', 'r+');
-        $stream = new Stream($stream, $loop);
+        $stream = class_exists('React\Stream\DuplexResourceStream') ? new DuplexResourceStream($stream, $loop) : new Stream($stream, $loop);
 
         $stream->pipe($request);
         $stream->emit('data', array('some'));

tests/ResponseTest.php

@@ -11,8 +11,7 @@ class ResponseTest extends TestCase
 
     public function setUp()
     {
-        $this->stream = $this->getMockBuilder('React\Stream\Stream')
-            ->disableOriginalConstructor()
+        $this->stream = $this->getMockBuilder('React\Stream\DuplexStreamInterface')
             ->getMock();
     }