style: set phpcs php version to 8.1 (#74)

simPod · Dec 14, 2022 · f868d20 · f868d20
1 parent 26bfe20
commit f868d20
Show file tree

Hide file tree

Showing 3 changed files with 18 additions and 18 deletions.
diff --git a/phpcs.xml.dist b/phpcs.xml.dist
@@ -6,7 +6,7 @@
     <arg name="cache" value=".phpcs-cache" />
     <arg name="colors" />
 
-    <config name="php_version" value="70400" />
+    <config name="php_version" value="81000" />
 
     <!-- Ignore warnings, show progress of the run and show sniff names -->
     <arg value="nps" />

diff --git a/src/Clients/Consumer/KafkaConsumer.php b/src/Clients/Consumer/KafkaConsumer.php
@@ -31,7 +31,7 @@ final class KafkaConsumer extends RdKafkaConsumer
 
     private bool $shouldRun = true;
 
-    public function __construct(ConsumerConfig $config, ?LoggerInterface $logger = null)
+    public function __construct(ConsumerConfig $config, LoggerInterface|null $logger = null)
     {
         $this->logger = $logger ?? new NullLogger();
 
@@ -48,7 +48,7 @@ function (RdKafkaConsumer $kafka, int $err, string $reason): void {
 
         $rebalanceCallback =
             /** @param array<string, TopicPartition>|null $partitions */
-            function (RdKafkaConsumer $kafka, int $err, ?array $partitions = null): void {
+            function (RdKafkaConsumer $kafka, int $err, array|null $partitions = null): void {
                 switch ($err) {
                     case RD_KAFKA_RESP_ERR__ASSIGN_PARTITIONS:
                         $this->logger->debug(
@@ -92,8 +92,8 @@ static function (TopicPartition $partition): string {
     public function start(
         int $timeoutMs,
         callable $onSuccess,
-        ?callable $onPartitionEof = null,
-        ?callable $onTimedOut = null
+        callable|null $onPartitionEof = null,
+        callable|null $onTimedOut = null,
     ): void {
         $this->doStart($timeoutMs, $onSuccess, $onPartitionEof, $onTimedOut);
     }
@@ -105,8 +105,8 @@ public function start(
     public function startBatch(
         int $maxBatchSize,
         int $timeoutMs,
-        ?callable $processRecord = null,
-        ?callable $onBatchProcessed = null
+        callable|null $processRecord = null,
+        callable|null $onBatchProcessed = null,
     ): void {
         $batchTime       = new BatchTime($timeoutMs, new DateTimeImmutable());
         $consumerRecords = new ConsumerRecords();
@@ -119,7 +119,7 @@ function (Message $message) use (
                 $batchTime,
                 $processRecord,
                 $onBatchProcessed,
-                $consumerRecords
+                $consumerRecords,
             ): void {
                 $consumerRecords->add($message);
                 if ($processRecord !== null) {
@@ -152,8 +152,8 @@ function (Message $message) use (
     private function doStart(
         int $timeoutMs,
         callable $onSuccess,
-        ?callable $onPartitionEof = null,
-        ?callable $onTimedOut = null
+        callable|null $onPartitionEof = null,
+        callable|null $onTimedOut = null,
     ): void {
         $this->registerSignals($this->shouldRun);
 
@@ -199,14 +199,14 @@ private function doStart(
     private function checkBatchTimedOut(
         int $timeoutMs,
         BatchTime $batchTime,
-        ?callable $onBatchProcessed,
-        ConsumerRecords $consumerRecords
+        callable|null $onBatchProcessed,
+        ConsumerRecords $consumerRecords,
     ): callable {
         return static function () use (
             $timeoutMs,
             $batchTime,
             $onBatchProcessed,
-            $consumerRecords
+            $consumerRecords,
         ): void {
             $remainingTimeout = $batchTime->endMsTimestamp - (new DateTimeImmutable())->getTimestamp() * 1000;
 

diff --git a/src/Clients/Producer/KafkaProducer.php b/src/Clients/Producer/KafkaProducer.php
@@ -22,7 +22,7 @@ class KafkaProducer extends Producer
     private $exitCallback;
 
     /** @param callable(KafkaProducer):void|null $exitCallback */
-    public function __construct(ProducerConfig $config, ?callable $exitCallback = null)
+    public function __construct(ProducerConfig $config, callable|null $exitCallback = null)
     {
         $this->exitCallback = $exitCallback;
 
@@ -41,11 +41,11 @@ public function __destruct()
     /** @param array<string, string>|null $headers */
     public function produce(
         string $topicName,
-        ?int $partition,
+        int|null $partition,
         string $value,
-        ?string $key = null,
-        ?array $headers = null,
-        ?int $timestampMs = null
+        string|null $key = null,
+        array|null $headers = null,
+        int|null $timestampMs = null,
     ): void {
         if ($partition < 0) {
             throw new InvalidArgumentException(