PHP 8.3 fixes

.github/workflows/ci.yml

@@ -11,14 +11,15 @@ jobs:
     strategy:
       matrix:
         os:
-          - ubuntu-20.04
+          - ubuntu-22.04
         php:
+          - 8.3
+          - 8.2
           - 8.1
           - 8.0
           - 7.4
-          - 7.3
     steps:
-      - uses: actions/checkout@v2
+      - uses: actions/checkout@v4
       - uses: shivammathur/setup-php@v2
         with:
           php-version: ${{ matrix.php }}

composer.json

@@ -38,11 +38,11 @@
     },
     "require": {
         "react/http": "1.5.* | 1.6.* | 1.7.* | 1.8.*",
-        "voryx/event-loop": "^3.0 || ^2.0.2",
         "ratchet/rfc6455": "^0.3",
-        "reactivex/rxphp": "^2.0.1"
+        "reactivex/rxphp": "^2.0.1",
+        "react/event-loop": "^1.2"
     },
     "require-dev": {
-        "phpunit/phpunit": "^9"
+        "phpunit/phpunit": "^9 | ^10"
     }
 }

phpunit.xml

@@ -1,18 +1,8 @@
-<?xml version="1.0" encoding="utf-8" ?>
-<phpunit
-        backupGlobals="false"
-        backupStaticAttributes="false"
-        colors="true"
-        convertErrorsToExceptions="true"
-        convertNoticesToExceptions="true"
-        convertWarningsToExceptions="true"
-        processIsolation="false"
-        stopOnFailure="false"
-        bootstrap="test/bootstrap.php">
-    <testsuites>
-        <testsuite name="RxWebsocket Test">
-            <directory>test/</directory>
-        </testsuite>
-    </testsuites>
-
-</phpunit>
+<?xml version="1.0" encoding="utf-8"?>
+<phpunit xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" backupGlobals="false" colors="true" processIsolation="false" stopOnFailure="false" bootstrap="test/bootstrap.php" xsi:noNamespaceSchemaLocation="https://schema.phpunit.de/10.5/phpunit.xsd" cacheDirectory=".phpunit.cache" backupStaticProperties="false">
+  <testsuites>
+    <testsuite name="RxWebsocket Test">
+      <directory>test/</directory>
+    </testsuite>
+  </testsuites>
+</phpunit>

src/Client.php

@@ -46,7 +46,7 @@ public function __construct(string $url, bool $useMessageObject = false, array $
         $this->url              = $url;
         $this->useMessageObject = $useMessageObject;
         $this->subProtocols     = $subProtocols;
-        $this->loop             = $loop ?: \EventLoop\getLoop();
+        $this->loop             = $loop ?: \React\EventLoop\Loop::get();
         $this->connector        = $connector;
         $this->keepAlive        = $keepAlive;
         $this->headers          = $headers;

src/MessageSubject.php

@@ -107,8 +107,8 @@ function (FrameInterface $frame) {
             ->merge($keepAliveObs)
             ->subscribe(
                 [$messageBuffer, 'onData'],
-                [$this, 'parent::onError'],
-                [$this, 'parent::onCompleted']
+                function (\Throwable $e) { parent::onError($e); },
+                function () { parent::onCompleted(); }
             );
 
         $this->subProtocol = $subProtocol;

src/Server.php

@@ -35,7 +35,7 @@ public function __construct(string $bindAddressOrPort, bool $useMessageObject =
         $this->bindAddress      = $bindAddressOrPort;
         $this->useMessageObject = $useMessageObject;
         $this->subProtocols     = $subProtocols;
-        $this->loop             = $loop ?: \EventLoop\getLoop();
+        $this->loop             = $loop ?: \React\EventLoop\Loop::get();
         $this->keepAlive        = $keepAlive;
     }
 

test/ClientTest.php

@@ -38,7 +38,7 @@ public function testPassthroughOfHeaders() {
             ->getMock();
         $connection
             ->method('write')
-            ->with($this->callback(function($data) use (&$writtenData) { $writtenData .= $data; }))
+            ->with($this->callback(function($data) use (&$writtenData) { $writtenData .= $data; return true;}))
             ->willReturn(true);
 
 

test/ServerTest.php

@@ -2,6 +2,7 @@
 
 namespace Rx\Websocket\Test;
 
+use React\EventLoop\Loop;
 use function EventLoop\addTimer;
 use function EventLoop\getLoop;
 use Rx\Websocket\Client;
@@ -16,11 +17,11 @@ public function testServerShutsDown()
 
         $serverDisp = $server->subscribe();
 
-        addTimer(0.1, function () use ($serverDisp) {
+        Loop::addTimer(0.1, function () use ($serverDisp) {
             $serverDisp->dispose();
         });
 
-        getLoop()->run();
+        Loop::get()->run();
 
         // we are making sure it is not hanging - if it gets here it worked
         $this->assertTrue(true);
@@ -38,7 +39,7 @@ function (MessageSubject $ms) {
 
         $value = null;
 
-        addTimer(0.1, function () use (&$value) {
+        Loop::addTimer(0.1, function () use (&$value) {
             $client = new Client('ws://127.0.0.1:1236');
             $client
                 ->flatMap(function (MessageSubject $ms) {
@@ -52,8 +53,8 @@ function (MessageSubject $ms) {
                 });
         });
 
-        getLoop()->run();
+        Loop::get()->run();
 
         $this->assertEquals('olleH', $value);
     }
-}
+}

test/TestCase.php

@@ -25,7 +25,7 @@ public static function resetScheduler()
 
         foreach ($props as $prop) {
             $prop->setAccessible(true);
-            $prop->setValue(null);
+            $prop->setValue($prop, null);
             $prop->setAccessible(false);
         }
     }

test/ab/clientRunner.php

@@ -4,7 +4,7 @@
 
 const AGENT = "Websocket/0.0.0";
 
-echo "Using " . get_class(\EventLoop\getLoop()) . "\n";
+echo "Using " . get_class(\React\EventLoop\Loop::get()) . "\n";
 
 $runReports = function () {
     echo "Generating report.\n";
@@ -60,7 +60,7 @@ function ($error) use ($case, $deferred) {
         },
         function () use ($case, $deferred) {
             echo "Finished " . $case . "\n";
-            $deferred->resolve();
+            $deferred->resolve(null);
         }
     );
 
@@ -77,7 +77,7 @@ function () use ($case, $deferred) {
     $runNextCase = function () use (&$i, &$runNextCase, $testCount, $deferred, $runIndividualTest) {
         $i++;
         if ($i > $testCount) {
-            $deferred->resolve();
+            $deferred->resolve(null);
             return;
         }
         $runIndividualTest($i, 60000)->then(function ($result) use ($runIndividualTest, &$i) {

test/ab/testServer.php

@@ -4,7 +4,7 @@
 
 require_once __DIR__ . '/../bootstrap.php';
 
-$timerObservable = Observable::emptyObservable();
+$timerObservable = Observable::empty();
 
 if ($argc > 1 && is_numeric($argv[1])) {
     echo "Setting test server to stop in " . $argv[1] . " seconds.\n";

test/bootstrap.php

@@ -16,3 +16,5 @@
         break;
     }
 }
+
+Rx\Scheduler::setDefaultFactory(function () { return new \Rx\Scheduler\EventLoopScheduler(\React\EventLoop\Loop::get()); });