Merge pull request #20 from WyriHaximus-labs/promise-3

Forward compatibility with react/promise 3

Author: clue

composer.json

@@ -36,7 +36,7 @@
     "require": {
         "php": ">=5.3",
         "react/stream": "^1.0 || ^0.7 || ^0.6 || ^0.5 || ^0.4.6",
-        "react/promise": "^2.1 || ^1.2"
+        "react/promise": "^3 || ^2.1 || ^1.2"
     },
     "require-dev": {
         "react/event-loop": "^1.0 || ^0.5 || ^0.4 || ^0.3",

src/UnwrapReadableStream.php

@@ -4,7 +4,6 @@
 
 use Evenement\EventEmitter;
 use InvalidArgumentException;
-use React\Promise\CancellablePromiseInterface;
 use React\Promise\PromiseInterface;
 use React\Stream\ReadableStreamInterface;
 use React\Stream\Util;
@@ -126,7 +125,7 @@ public function close()
         $this->closed = true;
 
         // try to cancel promise once the stream closes
-        if ($this->promise instanceof CancellablePromiseInterface) {
+        if ($this->promise !== null && \method_exists($this->promise, 'cancel')) {
             $this->promise->cancel();
         }
         $this->promise = null;

src/UnwrapWritableStream.php

@@ -4,7 +4,6 @@
 
 use Evenement\EventEmitter;
 use InvalidArgumentException;
-use React\Promise\CancellablePromiseInterface;
 use React\Promise\PromiseInterface;
 use React\Stream\WritableStreamInterface;
 
@@ -153,7 +152,7 @@ public function close()
         $this->closed = true;
 
         // try to cancel promise once the stream closes
-        if ($this->promise instanceof CancellablePromiseInterface) {
+        if ($this->promise !== null && \method_exists($this->promise, 'cancel')) {
             $this->promise->cancel();
         }
         $this->promise = $this->stream = null;