Use reactphp-block v1.5.0 and remove loop where possible

reactphp · Jan 13, 2022 · 4f2497b · 4f2497b
1 parent 82acd6c
commit 4f2497b
Show file tree

Hide file tree

Showing 16 changed files with 124 additions and 306 deletions.
diff --git a/composer.json b/composer.json
@@ -35,7 +35,7 @@
         "react/stream": "^1.2"
     },
     "require-dev": {
-        "clue/block-react": "^1.2",
+        "clue/block-react": "^1.5",
         "phpunit/phpunit": "^9.3 || ^5.7 || ^4.8.35",
         "react/promise-stream": "^1.2"
     },

diff --git a/tests/FdServerTest.php b/tests/FdServerTest.php
@@ -3,7 +3,6 @@
 namespace React\Tests\Socket;
 
 use Clue\React\Block;
-use React\EventLoop\Loop;
 use React\Promise\Promise;
 use React\Socket\ConnectionInterface;
 use React\Socket\FdServer;
@@ -303,12 +302,12 @@ public function testServerEmitsConnectionEventForNewConnection()
 
         $client = stream_socket_client('tcp://' . stream_socket_get_name($socket, false));
 
-        $server = new FdServer($fd, Loop::get());
+        $server = new FdServer($fd);
         $promise = new Promise(function ($resolve) use ($server) {
             $server->on('connection', $resolve);
         });
 
-        $connection = Block\await($promise, Loop::get(), 1.0);
+        $connection = Block\await($promise, null, 1.0);
 
         /**
          * @var ConnectionInterface $connection

diff --git a/tests/FunctionalConnectorTest.php b/tests/FunctionalConnectorTest.php
@@ -20,13 +20,11 @@ class FunctionalConnectorTest extends TestCase
     /** @test */
     public function connectionToTcpServerShouldSucceedWithLocalhost()
     {
-        $loop = Loop::get();
-
         $server = new TcpServer(9998);
 
         $connector = new Connector(array());
 
-        $connection = Block\await($connector->connect('localhost:9998'), $loop, self::TIMEOUT);
+        $connection = Block\await($connector->connect('localhost:9998'), null, self::TIMEOUT);
 
         $server->close();
 
@@ -65,11 +63,11 @@ public function testConnectTwiceWithoutHappyEyeBallsOnlySendsSingleDnsQueryDueTo
             fclose($client);
         });
 
-        $connection = Block\await($connector->connect('example.com:80'), Loop::get());
+        $connection = Block\await($connector->connect('example.com:80'));
         $connection->close();
         $this->assertEquals(1, $received);
 
-        $connection = Block\await($connector->connect('example.com:80'), Loop::get());
+        $connection = Block\await($connector->connect('example.com:80'));
         $connection->close();
         $this->assertEquals(1, $received);
 
@@ -85,11 +83,9 @@ public function connectionToRemoteTCP4n6ServerShouldResultInOurIP()
         // max_nesting_level was set to 100 for PHP Versions < 5.4 which resulted in failing test for legacy PHP
         ini_set('xdebug.max_nesting_level', 256);
 
-        $loop = Loop::get();
-
         $connector = new Connector(array('happy_eyeballs' => true));
 
-        $ip = Block\await($this->request('dual.tlund.se', $connector), $loop, self::TIMEOUT);
+        $ip = Block\await($this->request('dual.tlund.se', $connector), null, self::TIMEOUT);
 
         $this->assertNotFalse(inet_pton($ip));
     }
@@ -100,12 +96,10 @@ public function connectionToRemoteTCP4n6ServerShouldResultInOurIP()
      */
     public function connectionToRemoteTCP4ServerShouldResultInOurIP()
     {
-        $loop = Loop::get();
-
         $connector = new Connector(array('happy_eyeballs' => true));
 
         try {
-            $ip = Block\await($this->request('ipv4.tlund.se', $connector), $loop, self::TIMEOUT);
+            $ip = Block\await($this->request('ipv4.tlund.se', $connector), null, self::TIMEOUT);
         } catch (\Exception $e) {
             $this->checkIpv4();
             throw $e;
@@ -121,12 +115,10 @@ public function connectionToRemoteTCP4ServerShouldResultInOurIP()
      */
     public function connectionToRemoteTCP6ServerShouldResultInOurIP()
     {
-        $loop = Loop::get();
-
         $connector = new Connector(array('happy_eyeballs' => true));
 
         try {
-            $ip = Block\await($this->request('ipv6.tlund.se', $connector), $loop, self::TIMEOUT);
+            $ip = Block\await($this->request('ipv6.tlund.se', $connector), null, self::TIMEOUT);
         } catch (\Exception $e) {
             $this->checkIpv6();
             throw $e;
@@ -142,30 +134,28 @@ public function testCancelPendingTlsConnectionDuringTlsHandshakeShouldCloseTcpCo
             $this->markTestSkipped('Not supported on legacy HHVM');
         }
 
-        $loop = Loop::get();
-
         $server = new TcpServer(0);
         $uri = str_replace('tcp://', 'tls://', $server->getAddress());
 
         $connector = new Connector(array());
         $promise = $connector->connect($uri);
 
         $deferred = new Deferred();
-        $server->on('connection', function (ConnectionInterface $connection) use ($promise, $deferred, $loop) {
+        $server->on('connection', function (ConnectionInterface $connection) use ($promise, $deferred) {
             $connection->on('close', function () use ($deferred) {
                 $deferred->resolve();
             });
 
-            $loop->futureTick(function () use ($promise) {
+            Loop::futureTick(function () use ($promise) {
                 $promise->cancel();
             });
         });
 
-        Block\await($deferred->promise(), $loop, self::TIMEOUT);
+        Block\await($deferred->promise(), null, self::TIMEOUT);
         $server->close();
 
         try {
-            Block\await($promise, $loop, self::TIMEOUT);
+            Block\await($promise, null, self::TIMEOUT);
             $this->fail();
         } catch (\Exception $e) {
             $this->assertInstanceOf('RuntimeException', $e);