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