Removed Pipeline::closure

Author: norberttech

src/core/etl/src/Flow/ETL/Pipeline.php

@@ -13,8 +13,6 @@ interface Pipeline
 {
     public function add(Loader|Transformer $pipe) : self;
 
-    public function closure(FlowContext $context) : void;
-
     public function has(string $transformerClass) : bool;
 
     public function pipes() : Pipes;

src/core/etl/src/Flow/ETL/Pipeline/BatchingPipeline.php

@@ -30,11 +30,6 @@ public function add(Loader|Transformer $pipe) : self
         return $this;
     }
 
-    public function closure(FlowContext $context) : void
-    {
-        $this->pipeline->closure($context);
-    }
-
     public function has(string $transformerClass) : bool
     {
         return $this->pipeline->has($transformerClass);

src/core/etl/src/Flow/ETL/Pipeline/CachingPipeline.php

@@ -19,11 +19,6 @@ public function add(Loader|Transformer $pipe) : Pipeline
         return $this;
     }
 
-    public function closure(FlowContext $context) : void
-    {
-        $this->pipeline->closure($context);
-    }
-
     public function has(string $transformerClass) : bool
     {
         return $this->pipeline->has($transformerClass);

src/core/etl/src/Flow/ETL/Pipeline/CollectingPipeline.php

@@ -28,11 +28,6 @@ public function add(Loader|Transformer $pipe) : self
         return $this;
     }
 
-    public function closure(FlowContext $context) : void
-    {
-        $this->pipeline->closure($context);
-    }
-
     public function has(string $transformerClass) : bool
     {
         return $this->pipeline->has($transformerClass);

src/core/etl/src/Flow/ETL/Pipeline/GroupByPipeline.php

@@ -22,11 +22,6 @@ public function add(Loader|Transformer $pipe) : self
         return $this;
     }
 
-    public function closure(FlowContext $context) : void
-    {
-        $this->pipeline->closure($context);
-    }
-
     public function has(string $transformerClass) : bool
     {
         return $this->pipeline->has($transformerClass);

src/core/etl/src/Flow/ETL/Pipeline/LinkedPipeline.php

@@ -23,11 +23,6 @@ public function add(Loader|Transformer $pipe) : Pipeline
         return $this;
     }
 
-    public function closure(FlowContext $context) : void
-    {
-        $this->pipeline->closure($context);
-    }
-
     public function has(string $transformerClass) : bool
     {
         return $this->pipeline->has($transformerClass);

src/core/etl/src/Flow/ETL/Pipeline/PartitioningPipeline.php

@@ -36,11 +36,6 @@ public function add(Loader|Transformer $pipe) : Pipeline
         return $this;
     }
 
-    public function closure(FlowContext $context) : void
-    {
-        $this->pipeline->closure($context);
-    }
-
     public function has(string $transformerClass) : bool
     {
         return $this->pipeline->has($transformerClass);

src/core/etl/src/Flow/ETL/Pipeline/SynchronousPipeline.php

@@ -29,15 +29,6 @@ public function add(Loader|Transformer $pipe) : self
         return $this;
     }
 
-    public function closure(FlowContext $context) : void
-    {
-        foreach ($this->pipes->all() as $pipe) {
-            if ($pipe instanceof Loader && $pipe instanceof Closure) {
-                $pipe->closure($context);
-            }
-        }
-    }
-
     public function has(string $transformerClass) : bool
     {
         return $this->pipes->has($transformerClass);
@@ -84,7 +75,11 @@ public function process(FlowContext $context) : \Generator
             }
         }
 
-        $this->closure($context);
+        foreach ($this->pipes->all() as $pipe) {
+            if ($pipe instanceof Loader && $pipe instanceof Closure) {
+                $pipe->closure($context);
+            }
+        }
     }
 
     public function setSource(Extractor $extractor) : self

src/core/etl/src/Flow/ETL/Pipeline/VoidPipeline.php

@@ -17,11 +17,6 @@ public function add(Loader|Transformer $pipe) : self
         return $this;
     }
 
-    public function closure(FlowContext $context) : void
-    {
-        $this->pipeline->closure($context);
-    }
-
     public function has(string $transformerClass) : bool
     {
         return $this->pipeline->has($transformerClass);