From ca1d9b95f7e62b9efd8333cf9816a5d3c9df3b12 Mon Sep 17 00:00:00 2001
From: Michael Schimmel <schimmel@mycelium.de>
Date: Wed, 21 Jan 2026 16:13:45 +0100
Subject: [PATCH] DataStream updated

---
 AuraTrader/MainForm.pas      | 6 +++---
 Src/Myc.Trade.DataStream.pas | 8 ++++----
 2 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/AuraTrader/MainForm.pas b/AuraTrader/MainForm.pas
index bc1359e..f042494 100644
--- a/AuraTrader/MainForm.pas
+++ b/AuraTrader/MainForm.pas
@@ -337,7 +337,7 @@ begin
     var panel := pnlChart.AddPanel;
     panel.AddDoubleSeries(equity, TAlphaColors.Blue, 3);
 
-    FProcessDone := FProcessDone + (FServer as IM1FileServer).ProcessData(Symbol, terminated, ticker.Consumer);
+    FProcessDone := FProcessDone + (FServer as IM1DataServer).ProcessData(Symbol, terminated, ticker.Consumer);
 
 end;
 
@@ -599,14 +599,14 @@ begin
     var OhlcPoint := lastPrice.Chain<TDataPoint<TOhlcItem>>(TTradeConverter.CreateTickAggregation(Timeframe));
     OhlcPoint.CreateLink(Consumer);
 
-    FProcessDone := FProcessDone + (FServer as ITickFileServer).ProcessData(Symbol, terminated, ticker.Consumer);
+    FProcessDone := FProcessDone + (FServer as ITickDataServer).ProcessData(Symbol, terminated, ticker.Consumer);
 {$else}
 
     var ticker := TConverter.CreateTicker<TDataPoint<TOhlcItem>>;
 
     ticker.Producer.Chain(Consumer);
 
-    FProcessDone := FProcessDone + (FServer as IM1FileServer).ProcessData(Symbol, terminated, ticker.Consumer);
+    FProcessDone := FProcessDone + (FServer as IM1DataServer).ProcessData(Symbol, terminated, ticker.Consumer);
 {$endif}
 end;
 
diff --git a/Src/Myc.Trade.DataStream.pas b/Src/Myc.Trade.DataStream.pas
index 3a98484..6710961 100644
--- a/Src/Myc.Trade.DataStream.pas
+++ b/Src/Myc.Trade.DataStream.pas
@@ -115,20 +115,20 @@ type
         property Path: String read GetPath;
     end;
 
-    ITickFileServer = interface(IDataServer<TTickRecord>)
+    ITickDataServer = interface(IDataServer<TTickRecord>)
         ['{A6DE8B82-B0FB-48DB-A39A-CE91D861C5D2}']
     end;
 
-    TTickFileServer = class(TDataServer<TTickRecord, TTickRecord>, ITickFileServer)
+    TTickFileServer = class(TDataServer<TTickRecord, TTickRecord>, ITickDataServer)
     protected
         function MapRecord(const RecordBuffer: TTickRecord): TDataPoint<TTickRecord>; override;
     end;
 
-    IM1FileServer = interface(IDataServer<TOhlcItem>)
+    IM1DataServer = interface(IDataServer<TOhlcItem>)
         ['{7BB980D9-1969-49A4-991F-908F2DDAC1A0}']
     end;
 
-    TM1FileServer = class(TDataServer<TOhlcItem, TM1Record>, IM1FileServer)
+    TM1FileServer = class(TDataServer<TOhlcItem, TM1Record>, IM1DataServer)
     protected
         function MapRecord(const RecordBuffer: TM1Record): TDataPoint<TOhlcItem>; override;
     end;