Adds a closure method to TransformerLoader to delegate generator stop…

… signals to proxied loaders
flow-php · Feb 22, 2025 · d540e0c · d540e0c
1 parent f2a17fc
commit d540e0c
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/src/core/etl/src/Flow/ETL/Loader/TransformerLoader.php b/src/core/etl/src/Flow/ETL/Loader/TransformerLoader.php
@@ -7,7 +7,7 @@
 use function Flow\ETL\DSL\{df, from_rows};
 use Flow\ETL\{FlowContext, Loader, Rows, Transformation, Transformer};
 
-final readonly class TransformerLoader implements Loader, OverridingLoader
+final readonly class TransformerLoader implements Loader, OverridingLoader, Closure
 {
     public function __construct(
         private Transformer|Transformation $transformer,
@@ -30,4 +30,11 @@ public function loaders() : array
     {
         return [$this->loader];
     }
+
+    public function closure(FlowContext $context) : void
+    {
+        if ($this->loader instanceof Closure) {
+            $this->loader->closure($context);
+        }
+    }
 }