Pipe Optimization

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