Applied suggestions

Author: sebprt

src/PipelineProxy.php

@@ -18,24 +18,33 @@
 
 class PipelineProxy implements PipelineRuntimeInterface
 {
-    private $factory;
+    /** @var list<callable> $callbacks */
+    private $callback;
+
+    private array $callbacks = [];
+    private PipelineRuntimeInterface $decorated;
 
     public function __construct(
-        callable $factory,
-        private readonly ConsoleOutput $output,
-        private readonly PipelineInterface&WalkableInterface $pipeline,
-        private readonly State\StateOutput\Workflow $state,
-        private readonly string $filename,
-    ) {
-        $this->factory = $factory;
+        callable $callback,
+        ConsoleOutput $output,
+        PipelineInterface&WalkableInterface $pipeline,
+        State\StateOutput\Workflow $state,
+        string $filename,
+    )
+    {
+        $this->decorated = new PipelineConsoleRuntime($output, $pipeline, $state->withPipeline($filename));
+        $this->callback = $callback;
     }
 
     public function extract(
         ExtractorInterface $extractor,
         RejectionInterface $rejection,
         StateInterface $state,
-    ): self {
-        $this->pipeline->extract($extractor, $rejection, $state);
+    ): self
+    {
+        $this->callbacks[] = function () use ($extractor, $rejection, $state): void {
+            $this->decorated->extract($extractor, $rejection, $state);
+        };
 
         return $this;
     }
@@ -44,8 +53,11 @@ public function transform(
         TransformerInterface $transformer,
         RejectionInterface $rejection,
         StateInterface $state,
-    ): self {
-        $this->pipeline->transform($transformer, $rejection, $state);
+    ): self
+    {
+        $this->callbacks[] = function () use ($transformer, $rejection, $state): void {
+            $this->decorated->transform($transformer, $rejection, $state);
+        };
 
         return $this;
     }
@@ -54,18 +66,23 @@ public function load(
         LoaderInterface $loader,
         RejectionInterface $rejection,
         StateInterface $state,
-    ): self {
-        $this->pipeline->load($loader, $rejection, $state);
+    ): self
+    {
+        $this->callbacks[] = function () use ($loader, $rejection, $state): void {
+            $this->decorated->load($loader, $rejection, $state);
+        };
 
         return $this;
     }
 
     public function run(int $interval = 1000): int
     {
-        $runtime = new PipelineConsoleRuntime($this->output, $this->pipeline, $this->state->withPipeline($this->filename));
+        foreach ($this->callbacks as $callback) {
+            $callback($this->callback);
+        }
 
-        $pipeline = ($this->factory)($runtime);
+        $this->callbacks = [];
 
-        return $pipeline->run($interval);
+        return $this->decorated->run($interval);
     }
 }