Forward compatibility with react/promise 3

reactphp · Jan 31, 2020 · ec2d719 · ec2d719
1 parent a80b842
commit ec2d719
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/composer.json b/composer.json
@@ -20,7 +20,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": "dev-master as 3.0.0 || ^2.1 || ^1.2"
     },
     "require-dev": {
         "react/event-loop": "^1.0 || ^0.5 || ^0.4 || ^0.3",

diff --git a/src/UnwrapReadableStream.php b/src/UnwrapReadableStream.php
@@ -126,7 +126,7 @@ public function close()
         $this->closed = true;
 
         // try to cancel promise once the stream closes
-        if ($this->promise instanceof CancellablePromiseInterface) {
+        if ($this->promise instanceof CancellablePromiseInterface  || (method_exists($this->promise, 'cancel') && $this->promise instanceof PromiseInterface)) {
             $this->promise->cancel();
         }
         $this->promise = null;

diff --git a/src/UnwrapWritableStream.php b/src/UnwrapWritableStream.php
@@ -153,7 +153,7 @@ public function close()
         $this->closed = true;
 
         // try to cancel promise once the stream closes
-        if ($this->promise instanceof CancellablePromiseInterface) {
+        if ($this->promise instanceof CancellablePromiseInterface  || (method_exists($this->promise, 'cancel') && $this->promise instanceof PromiseInterface)) {
             $this->promise->cancel();
         }
         $this->promise = $this->stream = null;