From d540e0cbdaf1bc3095fbb45ecbe6d42301cc3d39 Mon Sep 17 00:00:00 2001
From: Christian Chung <christian.m.chung@gmail.com>
Date: Sat, 22 Feb 2025 18:28:07 -0500
Subject: [PATCH] Adds a closure method to TransformerLoader to delegate
 generator stop signals to proxied loaders

---
 src/core/etl/src/Flow/ETL/Loader/TransformerLoader.php | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/src/core/etl/src/Flow/ETL/Loader/TransformerLoader.php b/src/core/etl/src/Flow/ETL/Loader/TransformerLoader.php
index 92bac620a..93c8649ca 100644
--- 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);
+        }
+    }
 }