Avoid using deprecated functions from clue/reactphp-block

Author: clue

tests/Query/TcpTransportExecutorTest.php

@@ -266,9 +266,9 @@ function ($e) use (&$exception) {
             }
         );
 
-        \Clue\React\Block\sleep(0.01);
+        \Clue\React\Block\await(\React\Promise\Timer\sleep(0.01));
         if ($exception === null) {
-            \Clue\React\Block\sleep(0.2);
+            \Clue\React\Block\await(\React\Promise\Timer\sleep(0.2));
         }
 
         /** @var \RuntimeException $exception */
@@ -438,9 +438,9 @@ function ($e) use (&$exception) {
             }
         );
 
-        \Clue\React\Block\sleep(0.01);
+        \Clue\React\Block\await(\React\Promise\Timer\sleep(0.01));
         if ($exception === null) {
-            \Clue\React\Block\sleep(0.2);
+            \Clue\React\Block\await(\React\Promise\Timer\sleep(0.2));
         }
 
         /** @var \RuntimeException $exception */
@@ -477,7 +477,7 @@ function ($e) use (&$wait) {
             }
         );
 
-        \Clue\React\Block\sleep(0.2);
+        \Clue\React\Block\await(\React\Promise\Timer\sleep(0.2));
         $this->assertTrue($wait);
 
         $this->assertNotNull($client);
@@ -514,7 +514,7 @@ function ($e) use (&$wait) {
             }
         );
 
-        \Clue\React\Block\sleep(0.2);
+        \Clue\React\Block\await(\React\Promise\Timer\sleep(0.2));
         $this->assertTrue($wait);
 
         $this->assertNotNull($client);
@@ -549,9 +549,9 @@ function ($e) use (&$exception) {
             }
         );
 
-        \Clue\React\Block\sleep(0.01);
+        \Clue\React\Block\await(\React\Promise\Timer\sleep(0.01));
         if ($exception === null) {
-            \Clue\React\Block\sleep(0.2);
+            \Clue\React\Block\await(\React\Promise\Timer\sleep(0.2));
         }
 
         /** @var \RuntimeException $exception */
@@ -601,9 +601,9 @@ function ($e) use (&$exception) {
             }
         );
 
-        \Clue\React\Block\sleep(0.01);
+        \Clue\React\Block\await(\React\Promise\Timer\sleep(0.01));
         if ($exception === null) {
-            \Clue\React\Block\sleep(0.2);
+            \Clue\React\Block\await(\React\Promise\Timer\sleep(0.2));
         }
 
         /** @var \RuntimeException $exception */
@@ -653,9 +653,9 @@ function ($e) use (&$exception) {
             }
         );
 
-        \Clue\React\Block\sleep(0.01);
+        \Clue\React\Block\await(\React\Promise\Timer\sleep(0.01));
         if ($exception === null) {
-            \Clue\React\Block\sleep(0.2);
+            \Clue\React\Block\await(\React\Promise\Timer\sleep(0.2));
         }
 
         /** @var \RuntimeException $exception */
@@ -688,7 +688,7 @@ public function testQueryResolvesIfServerSendsValidResponse()
         $query = new Query('google.com', Message::TYPE_A, Message::CLASS_IN);
 
         $promise = $executor->query($query);
-        $response = \Clue\React\Block\await($promise, null, 0.2);
+        $response = \Clue\React\Block\await(\React\Promise\Timer\timeout($promise, 0.2));
 
         $this->assertInstanceOf('React\Dns\Model\Message', $response);
     }

tests/Query/UdpTransportExecutorTest.php

@@ -273,7 +273,7 @@ function ($e) use (&$wait) {
             }
         );
 
-        \Clue\React\Block\sleep(0.2);
+        \Clue\React\Block\await(\React\Promise\Timer\sleep(0.2));
         $this->assertTrue($wait);
 
         $promise->cancel();
@@ -311,7 +311,7 @@ function ($e) use (&$wait) {
             }
         );
 
-        \Clue\React\Block\sleep(0.2);
+        \Clue\React\Block\await(\React\Promise\Timer\sleep(0.2));
         $this->assertTrue($wait);
 
         $promise->cancel();
@@ -347,7 +347,7 @@ public function testQueryRejectsIfServerSendsTruncatedResponse()
             'DNS query for google.com (A) failed: The DNS server udp://' . $address . ' returned a truncated result for a UDP query',
             defined('SOCKET_EMSGSIZE') ? SOCKET_EMSGSIZE : 90
         );
-        \Clue\React\Block\await($promise, null, 0.1);
+        \Clue\React\Block\await(\React\Promise\Timer\timeout($promise, 0.1));
     }
 
     public function testQueryResolvesIfServerSendsValidResponse()
@@ -373,7 +373,7 @@ public function testQueryResolvesIfServerSendsValidResponse()
         $query = new Query('google.com', Message::TYPE_A, Message::CLASS_IN);
 
         $promise = $executor->query($query);
-        $response = \Clue\React\Block\await($promise, null, 0.2);
+        $response = \Clue\React\Block\await(\React\Promise\Timer\timeout($promise, 0.2));
 
         $this->assertInstanceOf('React\Dns\Model\Message', $response);
     }