Fixed phpstan errors

Author: sebprt

src/Extractor.php

@@ -32,7 +32,7 @@ public static function withoutAuthentication(
         string $host,
         string $vhost,
         string $topic,
-        ?int $port = null,
+        int $port = null,
     ): self {
         $connection = new Client([
             'host' => $host,
@@ -52,7 +52,7 @@ public static function withAuthentication(
         string $topic,
         ?string $user,
         ?string $password,
-        ?int $port = null,
+        int $port = null,
     ): self {
         $connection = new Client([
             'host' => $host,

src/Loader.php

@@ -7,6 +7,7 @@
 use Bunny\Channel;
 use Bunny\Client;
 use Kiboko\Component\Bucket\AcceptanceResultBucket;
+use Kiboko\Component\Bucket\EmptyResultBucket;
 use Kiboko\Contract\Pipeline\LoaderInterface;
 
 final readonly class Loader implements LoaderInterface
@@ -33,8 +34,8 @@ public static function withoutAuthentication(
         string $host,
         string $vhost,
         string $topic,
-        ?string $exchange = null,
-        ?int $port = null,
+        string $exchange = null,
+        int $port = null,
     ): self {
         $connection = new Client([
             'host' => $host,
@@ -54,8 +55,8 @@ public static function withAuthentication(
         string $topic,
         ?string $user,
         ?string $password,
-        ?string $exchange = null,
-        ?int $port = null,
+        string $exchange = null,
+        int $port = null,
     ): self {
         $connection = new Client([
             'host' => $host,
@@ -71,9 +72,9 @@ public static function withAuthentication(
 
     public function load(): \Generator
     {
-        $line = yield;
+        $line = new EmptyResultBucket();
 
-        while (true) {
+        while ($line) {
             $this->channel->publish(
                 json_encode($line, \JSON_THROW_ON_ERROR),
                 [

src/Rejection.php

@@ -34,8 +34,8 @@ public static function withoutAuthentication(
         string $host,
         string $vhost,
         string $topic,
-        ?string $exchange = null,
-        ?int $port = null,
+        string $exchange = null,
+        int $port = null,
     ): self {
         $connection = new Client([
             'host' => $host,
@@ -56,8 +56,8 @@ public static function withAuthentication(
         string $topic,
         ?string $user,
         ?string $password,
-        ?string $exchange = null,
-        ?int $port = null,
+        string $exchange = null,
+        int $port = null,
     ): self {
         $connection = new Client([
             'host' => $host,
@@ -71,7 +71,7 @@ public static function withAuthentication(
         return new self($connection, stepUuid: $stepUuid, topic: $topic, exchange: $exchange);
     }
 
-    public function reject(StepCodeInterface $step, object|array $rejection, ?\Throwable $exception = null): void
+    public function reject(StepCodeInterface $step, array|object $rejection, \Throwable $exception = null): void
     {
         $this->channel->publish(
             json_encode([
@@ -87,7 +87,7 @@ public function reject(StepCodeInterface $step, object|array $rejection, ?\Throw
         );
     }
 
-    public function rejectWithReason(StepCodeInterface $step, object|array $rejection, string $reason, ?\Throwable $exception = null): void
+    public function rejectWithReason(StepCodeInterface $step, array|object $rejection, string $reason, \Throwable $exception = null): void
     {
         $this->channel->publish(
             json_encode([

src/State.php

@@ -4,7 +4,6 @@
 
 namespace Kiboko\Component\Flow\RabbitMQ;
 
-use Kiboko\Contract\Pipeline\StepCodeInterface;
 use Kiboko\Contract\Pipeline\StepStateInterface;
 
 final class State implements StepStateInterface
@@ -17,8 +16,7 @@ public function __construct(
         private readonly StateManager $manager,
         private readonly string $stepCode,
         private readonly string $stepLabel,
-    ) {
-    }
+    ) {}
 
     public function accept(int $count = 1): void
     {

src/StateManager.php

@@ -73,7 +73,7 @@ private function sendUpdate(): void
         $this->channel->publish(
             json_encode([
                 'messageNumber' => ++$this->messageCount,
-                'id' => \uuid_create(\UUID_TYPE_RANDOM),
+                'id' => uuid_create(UUID_TYPE_RANDOM),
                 'date' => ['date' => $date->format('c'), 'tz' => $date->getTimezone()->getName()],
                 'stepsUpdates' => array_map(fn (State $step) => $step->toArray(), $this->steps),
             ], \JSON_THROW_ON_ERROR),