Merge pull request #8 from php-etl/feature/update-contracts

Updated php-etl contract versions

src/Lookup.php

@@ -24,9 +24,7 @@ class Lookup implements TransformerInterface, FlushableInterface
      * @param array<int,string>                          $beforeQueries
      * @param array<int,string>                          $afterQueries
      */
-    public function __construct(private readonly \PDO $connection, private readonly CompiledMapperInterface $mapper, private readonly array $beforeQueries = [], private readonly array $afterQueries = [], private readonly LoggerInterface $logger = new NullLogger())
-    {
-    }
+    public function __construct(private readonly \PDO $connection, private readonly CompiledMapperInterface $mapper, private readonly array $beforeQueries = [], private readonly array $afterQueries = [], private readonly LoggerInterface $logger = new NullLogger()) {}
 
     /**
      * @return \Generator<mixed>

tests/functional/PipelineRunner.php

@@ -7,20 +7,18 @@
 use Kiboko\Contract\Bucket\AcceptanceResultBucketInterface;
 use Kiboko\Contract\Bucket\RejectionResultBucketInterface;
 use Kiboko\Contract\Pipeline\PipelineRunnerInterface;
-use Kiboko\Contract\Pipeline\RejectionInterface;
-use Kiboko\Contract\Pipeline\StateInterface;
+use Kiboko\Contract\Pipeline\StepRejectionInterface;
+use Kiboko\Contract\Pipeline\StepStateInterface;
 
 final class PipelineRunner implements PipelineRunnerInterface
 {
     public function run(
         \Iterator $source,
         \Generator $async,
-        RejectionInterface $rejection,
-        StateInterface $state,
-    ): \Iterator {
-        $state->initialize();
-        $rejection->initialize();
-
+        StepRejectionInterface $rejection,
+        StepStateInterface $state,
+    ): \Iterator
+    {
         $source->rewind();
         $async->rewind();
 
@@ -40,8 +38,5 @@ public function run(
 
             $source->next();
         }
-
-        $rejection->teardown();
-        $state->teardown();
     }
 }