Fixing PHPStan level 4 issues

Author: gplanchat

composer.json

@@ -19,8 +19,7 @@
         "php": "^8.2",
         "psr/log": "^3.0",
         "php-etl/bucket": "*",
-        "php-etl/pipeline-contracts": "0.5.*",
-        "php-etl/bucket-contracts": "0.2.*"
+        "php-etl/pipeline-contracts": "0.5.*"
     },
     "require-dev": {
         "phpunit/php-invoker": "^4.0",

composer.lock

@@ -7,7 +7,7 @@
 use Kiboko\Contract\Pipeline\ExtractorInterface;
 
 /**
- * @template Type
+ * @template Type of non-empty-array<array-key, mixed>|object
  * @implements ExtractorInterface<Type>
  */
 class ArrayExtractor implements ExtractorInterface

src/Extractor/ArrayExtractor.php

@@ -7,7 +7,7 @@
 use Kiboko\Contract\Pipeline\ExtractorInterface;
 
 /**
- * @template Type
+ * @template Type of non-empty-array<array-key, mixed>|object
  * @implements ExtractorInterface<Type>
  */
 class IteratorExtractor implements ExtractorInterface

src/Extractor/IteratorExtractor.php

@@ -7,27 +7,27 @@
 use Kiboko\Contract\Bucket\ResultBucketInterface;
 
 /**
- * @template Type
+ * @template Type of non-empty-array<array-key, mixed>|object
  */
 class GeneratorWrapper
 {
-    /** @param \Iterator<array-key, Type> ...$iterators */
+    /** @param \Iterator<positive-int, Type> ...$iterators */
     public function rewind(\Iterator ...$iterators): void
     {
         foreach ($iterators as $iterator) {
             $iterator->rewind();
         }
     }
 
-    /** @param \Iterator<array-key, Type> ...$iterators */
+    /** @param \Iterator<positive-int, Type> ...$iterators */
     public function next(\Iterator ...$iterators): void
     {
         foreach ($iterators as $iterator) {
             $iterator->next();
         }
     }
 
-    /** @param \Iterator<array-key, Type> ...$iterators */
+    /** @param \Iterator<positive-int, Type> ...$iterators */
     public function valid(\Iterator ...$iterators): bool
     {
         foreach ($iterators as $iterator) {
@@ -41,7 +41,7 @@ public function valid(\Iterator ...$iterators): bool
 
     /**
      * @param Type $value
-     * @param \Generator<array-key, ResultBucketInterface<Type>, Type, void> ...$generators
+     * @param \Generator<positive-int, ResultBucketInterface<Type>, Type, void> ...$generators
      */
     public function send($value, \Generator ...$generators): \Generator
     {

src/GeneratorWrapper.php

@@ -5,7 +5,7 @@
 namespace Kiboko\Component\Pipeline\Loader;
 
 /**
- * @template Type
+ * @template Type of non-empty-array<array-key, mixed>|object
  *
  * @extends StreamLoader<Type>
  */

src/Loader/DebugLoader.php

@@ -5,7 +5,7 @@
 namespace Kiboko\Component\Pipeline\Loader;
 
 /**
- * @template Type
+ * @template Type of non-empty-array<array-key, mixed>|object
  *
  * @extends StreamLoader<Type>
  */

src/Loader/JSONStreamLoader.php

@@ -11,7 +11,7 @@
 use Psr\Log\LogLevel;
 
 /**
- * @template Type
+ * @template Type of non-empty-array<array-key, mixed>|object
  *
  * @implements LoaderInterface<Type, Type>
  */
@@ -21,12 +21,17 @@ public function __construct(private LoggerInterface $logger, private string $log
     {
     }
 
-    /** @return \Generator<mixed, AcceptanceResultBucket<Type|null>|EmptyResultBucket, Type|null, void> */
+    /** @return \Generator<positive-int, AcceptanceResultBucket<Type>|EmptyResultBucket, Type|null, void> */
     public function load(): \Generator
     {
         $line = yield new EmptyResultBucket();
         /** @phpstan-ignore-next-line */
         while (true) {
+            if ($line === null) {
+                $line = yield new EmptyResultBucket();
+                continue;
+            }
+
             $this->logger->log($this->logLevel, var_export($line, true));
             $line = yield new AcceptanceResultBucket($line);
         }

src/Loader/LogLoader.php

@@ -5,7 +5,7 @@
 namespace Kiboko\Component\Pipeline\Loader;
 
 /**
- * @template Type
+ * @template Type of non-empty-array<array-key, mixed>|object
  *
  * @extends StreamLoader<Type>
  */

src/Loader/StderrLoader.php

@@ -5,7 +5,7 @@
 namespace Kiboko\Component\Pipeline\Loader;
 
 /**
- * @template Type
+ * @template Type of non-empty-array<array-key, mixed>|object
  *
  * @extends StreamLoader<Type>
  */