From c73668643f141d2c637490375aad5f073df1acad Mon Sep 17 00:00:00 2001
From: Michael Schimmel <schimmel@mycelium.de>
Date: Sat, 14 Feb 2026 18:34:15 +0100
Subject: [PATCH] Pipe Optimization

---
 Src/Data/Myc.Data.Stream.pas | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/Src/Data/Myc.Data.Stream.pas b/Src/Data/Myc.Data.Stream.pas
index 9f93249..5896bb6 100644
--- a/Src/Data/Myc.Data.Stream.pas
+++ b/Src/Data/Myc.Data.Stream.pas
@@ -76,9 +76,6 @@ type
         procedure Push(const RowData: array of TScalar.TValue);
     end;
 
-    // Synchronizes multiple inputs via barrier and executes a transformation.
-    TPipeStream = class;
-
     { TPipeSource acts as a selective accumulator for a single field of a stream. }
     TPipeSource = class(TInterfacedObject, ISeries)
     public
@@ -112,6 +109,7 @@ type
 
     TPipeConfig = TArray<TArray<TScalarRecordField>>;
 
+    // Synchronizes multiple inputs via barrier and executes a transformation.
     TPipeStream = class(TCustomDataStream)
     public
         type