Updated the pipeline runner used for tests + ran php-cs-fixer

php-etl · Nov 22, 2023 · 87169db · 87169db
1 parent a551c76
commit 87169db
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 15 deletions.
diff --git a/src/FingersCrossed/Loader.php b/src/FingersCrossed/Loader.php
@@ -20,8 +20,7 @@ public function __construct(
         private ?array $columns = null,
         private bool $firstLineAsHeaders = true,
         private LoggerInterface $logger = new NullLogger()
-    ) {
-    }
+    ) {}
 
     public function load(): \Generator
     {

diff --git a/src/Safe/Loader.php b/src/Safe/Loader.php
@@ -20,8 +20,7 @@ public function __construct(
         private ?array $columns = null,
         private bool $firstLineAsHeaders = true,
         private LoggerInterface $logger = new NullLogger()
-    ) {
-    }
+    ) {}
 
     public function load(): \Generator
     {

diff --git a/tests/functional/PipelineRunner.php b/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();
     }
 }