Run tests on PHP 8.4 and update test environment

Author: PaulRotmann

.github/workflows/ci.yml

@@ -7,10 +7,11 @@ on:
 jobs:
   PHPUnit:
     name: PHPUnit (PHP ${{ matrix.php }})
-    runs-on: ubuntu-22.04
+    runs-on: ubuntu-24.04
     strategy:
       matrix:
         php:
+          - 8.4
           - 8.3
           - 8.2
           - 8.1
@@ -38,7 +39,7 @@ jobs:
 
   PHPUnit-hhvm:
     name: PHPUnit (HHVM)
-    runs-on: ubuntu-22.04
+    runs-on: ubuntu-24.04
     continue-on-error: true
     steps:
       - uses: actions/checkout@v4

src/Client.php

@@ -25,8 +25,8 @@ class Client
      * This value SHOULD NOT be given unless you're sure you want to explicitly use a
      * given event loop instance.
      *
-     * @param ?LoopInterface $loop
-     * @param ?MulticastFactory $multicast
+     * @param LoopInterface|null $loop
+     * @param MulticastFactory|null $multicast
      */
     public function __construct(LoopInterface $loop = null, MulticastFactory $multicast = null)
     {
@@ -36,7 +36,7 @@ public function __construct(LoopInterface $loop = null, MulticastFactory $multic
 
     public function search($searchTarget = 'ssdp:all', $mx = 2)
     {
-        $data  = "M-SEARCH * HTTP/1.1\r\n";
+        $data = "M-SEARCH * HTTP/1.1\r\n";
         $data .= "HOST: " . self::ADDRESS . "\r\n";
         $data .= "MAN: \"ssdp:discover\"\r\n";
         $data .= "MX: $mx\r\n";
@@ -46,11 +46,6 @@ public function search($searchTarget = 'ssdp:all', $mx = 2)
         $socket = $this->multicast->createSender();
         // TODO: The TTL for the IP packet SHOULD default to 2 and SHOULD be configurable.
 
-        $timer = $this->loop->addTimer($mx, function() use ($socket, &$deferred) {
-            $deferred->resolve();
-            $socket->close();
-        });
-
         $loop = $this->loop;
         $deferred = new Deferred(function () use ($socket, &$timer, $loop) {
             // canceling resulting promise cancels timer and closes socket
@@ -59,16 +54,21 @@ public function search($searchTarget = 'ssdp:all', $mx = 2)
             throw new RuntimeException('Cancelled');
         });
 
-        $that = $this;
-        $socket->on('message', function ($data, $remote) use ($deferred, $that) {
-            $message = $that->parseMessage($data, $remote);
+            $timer = $this->loop->addTimer($mx, function() use ($socket, $deferred) {
+                $deferred->resolve();
+                $socket->close();
+            });
 
-            $deferred->progress($message);
-        });
+                $that = $this;
+                $socket->on('message', function ($data, $remote) use ($deferred, $that) {
+                    $message = $that->parseMessage($data, $remote);
+
+                    $deferred->progress($message);
+                });
 
-        $socket->send($data, self::ADDRESS);
+                    $socket->send($data, self::ADDRESS);
 
-        return $deferred->promise();
+                    return $deferred->promise();
     }
 
     /** @internal */
@@ -81,4 +81,4 @@ public function parseMessage($message, $remote)
         );
         return $message;
     }
-}
+}