Forward compatibility with upcoming Promise v3

Author: clue

.github/workflows/ci.yml

@@ -26,6 +26,8 @@ jobs:
         uses: shivammathur/setup-php@v2
         with:
           php-version: ${{ matrix.php }}
+        env:
+          COMPOSER_TOKEN: ${{ secrets.GITHUB_TOKEN }}
       - run: composer install
       - run: vendor/bin/phpunit --coverage-text
         if: ${{ matrix.php >= 7.3 }}
@@ -35,6 +37,7 @@ jobs:
   PHPUnit-hhvm:
     name: PHPUnit (HHVM)
     runs-on: ubuntu-18.04
+    if: false # temporarily skipped until https://github.com/azjezz/setup-hhvm/issues/3 is addressed
     steps:
       - uses: actions/checkout@v2
       - uses: azjezz/setup-hhvm@v1

composer.json

@@ -18,12 +18,18 @@
     },
     "require": {
         "php": ">=5.3",
-        "react/socket": "^1.9",
         "react/event-loop": "^1.2",
-        "react/promise": "^2.1 || ^1.2.1",
-        "react/promise-timer": "^1.1"
+        "react/promise": "^3@dev || ^2.1 || ^1.2.1",
+        "react/promise-timer": "^1.9",
+        "react/socket": "dev-promise-3 as 1.12.0"
     },
     "require-dev": {
         "phpunit/phpunit": "^9.3 || ^5.7 || ^4.8"
-    }
+    },
+    "repositories": [
+        {
+            "type": "vcs",
+            "url": "https://github.com/WyriHaximus-labs/socket"
+        }
+    ]
 }

src/ConnectionManagerRepeat.php

@@ -6,7 +6,7 @@
 use InvalidArgumentException;
 use Exception;
 use React\Promise\Promise;
-use React\Promise\CancellablePromiseInterface;
+use React\Promise\PromiseInterface;
 
 class ConnectionManagerRepeat implements ConnectorInterface
 {
@@ -44,7 +44,7 @@ public function connect($uri)
             $tries = 0;
             $reject(new \RuntimeException('Cancelled'));
 
-            if ($pending instanceof CancellablePromiseInterface) {
+            if ($pending instanceof PromiseInterface && \method_exists($pending, 'cancel')) {
                 $pending->cancel();
             }
         });

src/Multiple/ConnectionManagerConcurrent.php

@@ -2,24 +2,22 @@
 
 namespace ConnectionManager\Extra\Multiple;
 
-use ConnectionManager\Extra\Multiple\ConnectionManagerConsecutive;
 use React\Promise;
-use React\Promise\CancellablePromiseInterface;
+use React\Promise\PromiseInterface;
 
 class ConnectionManagerConcurrent extends ConnectionManagerConsecutive
 {
     public function connect($uri)
     {
         $all = array();
         foreach ($this->managers as $connector) {
-            /* @var $connection Connector */
             $all []= $connector->connect($uri);
         }
         return Promise\any($all)->then(function ($conn) use ($all) {
             // a connection attempt succeeded
             // => cancel all pending connection attempts
             foreach ($all as $promise) {
-                if ($promise instanceof CancellablePromiseInterface) {
+                if ($promise instanceof PromiseInterface && \method_exists($promise, 'cancel')) {
                     $promise->cancel();
                 }
 

src/Multiple/ConnectionManagerConsecutive.php

@@ -2,10 +2,10 @@
 
 namespace ConnectionManager\Extra\Multiple;
 
-use React\Socket\ConnectorInterface;
 use React\Promise;
+use React\Promise\PromiseInterface;
+use React\Socket\ConnectorInterface;
 use UnderflowException;
-use React\Promise\CancellablePromiseInterface;
 
 class ConnectionManagerConsecutive implements ConnectorInterface
 {
@@ -54,7 +54,7 @@ public function tryConnection(array $managers, $uri)
             $managers = array();
             $reject(new \RuntimeException('Cancelled'));
 
-            if ($pending instanceof CancellablePromiseInterface) {
+            if ($pending instanceof PromiseInterface && \method_exists($pending, 'cancel')) {
                 $pending->cancel();
             }
         });