First upgrade step

Author: clue

composer.json

@@ -18,17 +18,17 @@
     },
     "require": {
         "php": ">=5.3",
-        "react/event-loop": "~0.3.0|~0.4.0",
-        "clue/buzz-react": "^0.5",
-        "react/promise": "~2.0|~1.1",
-        "clue/json-stream": "~0.1.0",
-        "rize/uri-template": "^0.3",
-        "clue/promise-stream-react": "^0.1"
+        "clue/buzz-react": "^1.0",
+        "clue/json-stream": "^0.1",
+        "react/event-loop": "^1.0 || ^0.5 || ^0.4 || ^0.3",
+        "react/promise": "^2.0 || ^1.1",
+        "react/promise-stream": "^1.0",
+        "rize/uri-template": "^0.3"
     },
     "require-dev": {
-        "clue/block-react": "~0.3.0",
-        "clue/caret-notation": "~0.2.0",
-        "clue/tar-react": "~0.1.0",
+        "clue/block-react": "^1.0 || ^0.3",
+        "clue/caret-notation": "^0.2",
+        "clue/tar-react": "^0.2 || ^0.1",
         "phpunit/phpunit": "^7.0 || ^6.0 || ^5.0 || ^4.8.35"
     }
 }

src/Io/StreamingParser.php

@@ -2,10 +2,10 @@
 
 namespace Clue\React\Docker\Io;
 
-use Clue\React\Promise\Stream;
 use Psr\Http\Message\ResponseInterface;
-use React\Promise\PromiseInterface;
 use React\Promise\Deferred;
+use React\Promise\PromiseInterface;
+use React\Promise\Stream;
 use React\Stream\ReadableStreamInterface;
 use RuntimeException;
 

tests/FunctionalClientTest.php

@@ -4,8 +4,8 @@
 
 use Clue\React\Block;
 use Clue\React\Docker\Client;
-use Clue\React\Promise\Stream;
 use React\EventLoop\Factory as LoopFactory;
+use React\Promise\Stream;
 
 class FunctionalClientTest extends TestCase
 {

tests/Io/StreamingParserTest.php

@@ -20,7 +20,7 @@ public function setUp()
 
     public function testJsonPassingRejectedPromiseResolvesWithClosedStream()
     {
-        $stream = $this->parser->parseJsonStream(Promise\reject());
+        $stream = $this->parser->parseJsonStream(Promise\reject(new \RuntimeException()));
 
         $this->assertInstanceOf('React\Stream\ReadableStreamInterface', $stream);
         $this->assertFalse($stream->isReadable());
@@ -62,7 +62,7 @@ public function testJsonResolvingPromiseWithWrongValueWillEmitErrorAndCloseEvent
 
     public function testPlainPassingRejectedPromiseResolvesWithClosedStream()
     {
-        $stream = $this->parser->parsePlainStream(Promise\reject());
+        $stream = $this->parser->parsePlainStream(Promise\reject(new \RuntimeException()));
 
         $this->assertInstanceOf('React\Stream\ReadableStreamInterface', $stream);
         $this->assertFalse($stream->isReadable());
@@ -102,12 +102,12 @@ public function testDeferredStreamErrorEventWillRejectPromise()
 
         $stream->emit('data', array('a'));
 
-        $stream->emit('error', array('value', 'ignord'));
+        $stream->emit('error', array(new \RuntimeException()));
 
         $stream->close();
 
         $this->expectPromiseReject($promise);
-        $promise->then(null, $this->expectCallableOnceWith('value'));
+        $promise->then(null, $this->expectCallableOnceWith($this->isInstanceOf('RuntimeException')));
     }
 
     public function testDeferredCancelingPromiseWillCloseStream()