Update to PHP 8.2

Author: daifma

.gitignore

@@ -4,3 +4,4 @@ composer.phar
 /vendor/
 docs/reactivex.github.io
 build/
+.idea

composer.json

@@ -20,7 +20,7 @@
         }
     ],
     "require": {
-        "php": ">=7.0.0",
+        "php": ">=8.2",
         "react/promise": "^3 || ~2.2"
     },
     "require-dev": {

src/Disposable/BinaryDisposable.php

@@ -6,33 +6,16 @@
 
 use Rx\DisposableInterface;
 
-/**
- * Class BinaryDisposable
- * @package Rx\Disposable
- */
 class BinaryDisposable implements DisposableInterface
 {
-    /** @var \Rx\DisposableInterface */
-    private $first;
-
-    /** @var \Rx\DisposableInterface */
-    private $second;
-
-    /** @var bool */
-    protected $isDisposed = false;
-
-    /**
-     * BinaryDisposable constructor.
-     * @param $first
-     * @param $second
-     */
-    public function __construct(DisposableInterface $first, DisposableInterface $second)
-    {
-        $this->first  = $first;
-        $this->second = $second;
+    public function __construct(
+        private null|DisposableInterface $first,
+        private null|DisposableInterface $second,
+        protected bool $isDisposed = false
+    ) {
     }
 
-    public function dispose()
+    public function dispose(): void
     {
         if ($this->isDisposed) {
             return;

src/Disposable/CallbackDisposable.php

@@ -8,15 +8,13 @@
 
 class CallbackDisposable implements DisposableInterface
 {
-    private $action;
-    private $disposed = false;
-
-    public function __construct(callable $action)
-    {
-        $this->action = $action;
+    public function __construct(
+        private \Closure $action,
+        private bool $disposed = false
+    ) {
     }
 
-    public function dispose()
+    public function dispose(): void
     {
         if ($this->disposed) {
             return;

src/Disposable/CompositeDisposable.php

@@ -8,15 +8,14 @@
 
 class CompositeDisposable implements DisposableInterface
 {
-    private $disposables;
-    private $isDisposed = false;
 
-    public function __construct(array $disposables = [])
-    {
-        $this->disposables = $disposables;
+    public function __construct(
+        private array $disposables = [],
+        private bool $isDisposed = false
+    ) {
     }
 
-    public function dispose()
+    public function dispose(): void
     {
         if ($this->isDisposed) {
             return;
@@ -32,7 +31,7 @@ public function dispose()
         }
     }
 
-    public function add(DisposableInterface $disposable)
+    public function add(DisposableInterface $disposable): void
     {
         if ($this->isDisposed) {
             $disposable->dispose();
@@ -65,12 +64,12 @@ public function contains(DisposableInterface $disposable): bool
         return in_array($disposable, $this->disposables, true);
     }
 
-    public function count()
+    public function count(): int
     {
         return count($this->disposables);
     }
 
-    public function clear()
+    public function clear(): void
     {
         $disposables       = $this->disposables;
         $this->disposables = [];

src/Disposable/EmptyDisposable.php

@@ -8,7 +8,7 @@
 
 class EmptyDisposable implements DisposableInterface
 {
-    public function dispose()
+    public function dispose(): void
     {
         // do nothing \o/
     }

src/Disposable/RefCountDisposable.php

@@ -8,17 +8,16 @@
 
 class RefCountDisposable implements DisposableInterface
 {
-    private $count = 0;
-    private $disposable;
-    private $isDisposed = false;
-    private $isPrimaryDisposed = false;
 
-    public function __construct(DisposableInterface $disposable)
-    {
-        $this->disposable = $disposable;
+    public function __construct(
+        private readonly DisposableInterface $disposable,
+        private int                          $count = 0,
+        private bool                         $isDisposed = false,
+        private bool                         $isPrimaryDisposed = false
+    ) {
     }
 
-    public function dispose()
+    public function dispose(): void
     {
         if ($this->isDisposed) {
             return;
@@ -32,13 +31,13 @@ public function dispose()
         }
     }
 
-    public function getDisposable()
+    public function getDisposable(): DisposableInterface|CallbackDisposable
     {
         if (!$this->isDisposed) {
             return $this->createInnerDisposable();
         }
 
-        return new CallbackDisposable(function () {
+        return new CallbackDisposable(function (): void {
         }); // no op
     }
 
@@ -57,7 +56,7 @@ private function createInnerDisposable(): DisposableInterface
         $this->count++;
         $isInnerDisposed = false;
 
-        return new CallbackDisposable(function () use (&$isInnerDisposed) {
+        return new CallbackDisposable(function () use (&$isInnerDisposed): void {
             if ($this->isDisposed()) {
                 return;
             }

src/Disposable/ScheduledDisposable.php

@@ -9,30 +9,22 @@
 
 class ScheduledDisposable implements DisposableInterface
 {
-    /** @var DisposableInterface */
-    private $disposable;
-
-    /** @var SchedulerInterface */
-    private $scheduler;
-
-    /** @var bool */
-    protected $isDisposed = false;
-
-    public function __construct(SchedulerInterface $scheduler, DisposableInterface $disposable)
-    {
-        $this->scheduler  = $scheduler;
-        $this->disposable = $disposable;
+    public function __construct(
+        private SchedulerInterface   $scheduler,
+        private  DisposableInterface $disposable,
+        protected bool               $isDisposed = false
+    ) {
     }
 
-    public function dispose()
+    public function dispose(): void
     {
         if ($this->isDisposed) {
             return;
         }
 
         $this->isDisposed = true;
 
-        $this->scheduler->schedule(function () {
+        $this->scheduler->schedule(function (): void {
             $this->disposable->dispose();
         });
     }

src/Disposable/SerialDisposable.php

@@ -6,19 +6,13 @@
 
 use Rx\DisposableInterface;
 
-/**
- * Class SerialDisposable
- * @package Rx\Disposable
- */
 class SerialDisposable implements DisposableInterface
 {
-    /** @var bool */
-    private $isDisposed = false;
+    private bool $isDisposed = false;
 
-    /** @var DisposableInterface */
-    private $disposable = null;
+    private ?DisposableInterface $disposable = null;
 
-    public function dispose()
+    public function dispose(): void
     {
         if ($this->isDisposed) {
             return;
@@ -33,18 +27,12 @@ public function dispose()
         }
     }
 
-    /**
-     * @return DisposableInterface
-     */
-    public function getDisposable()
+    public function getDisposable(): null|DisposableInterface
     {
         return $this->disposable;
     }
 
-    /**
-     * @param DisposableInterface $disposable
-     */
-    public function setDisposable(DisposableInterface $disposable)
+    public function setDisposable(DisposableInterface $disposable): void
     {
         $shouldDispose = $this->isDisposed;
 

src/Disposable/SingleAssignmentDisposable.php

@@ -9,10 +9,10 @@
 
 class SingleAssignmentDisposable implements DisposableInterface
 {
-    private $current;
-    private $isDisposed = false;
+    private null|DisposableInterface $current = null;
+    private bool $isDisposed = false;
 
-    public function dispose()
+    public function dispose(): void
     {
         $old = null;
 
@@ -27,7 +27,7 @@ public function dispose()
         }
     }
 
-    public function setDisposable(DisposableInterface $disposable = null)
+    public function setDisposable(DisposableInterface $disposable = null): void
     {
         if ($this->current) {
             throw new RuntimeException('Disposable has already been assigned.');
@@ -42,12 +42,12 @@ public function setDisposable(DisposableInterface $disposable = null)
         }
     }
 
-    public function getDisposable()
+    public function getDisposable(): null|DisposableInterface
     {
         return $this->current;
     }
 
-    public function isDisposed()
+    public function isDisposed(): bool
     {
         return $this->isDisposed;
     }