diff --git a/src/Lookup.php b/src/Lookup.php
index f93a1e5..87c13d5 100644
--- a/src/Lookup.php
+++ b/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>
diff --git a/tests/functional/PipelineRunner.php b/tests/functional/PipelineRunner.php
index 56748bf..cac24d7 100644
--- 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();
     }
 }