Changeset 312 for Generics/TemplateGenerics/Generic/GenericStream.inc

Timestamp:

Jan 9, 2012, 2:22:31 PM (13 years ago)

Author:

chronos

Message:

• Modified: TGStream is now implemented. TMemoryStreamByte have additional methods usable for byte streams.
• Added: Few other missing methods in TGList.

File:

• Generics/TemplateGenerics/Generic/GenericStream.inc (modified) (2 diffs)

Generics/TemplateGenerics/Generic/GenericStream.inc

@@ -1 +1 @@
 {$IFDEF INTERFACE}
 
-TGStreamDataEvent = procedure (Item: TGStreamItem) of object;
+TGStreamItemArray = array of TGStreamItem;
 
-// TGStream<TStreamItem> = class
+// TGStream<TGStreamIndex, TGStreamItem> = class
 TGStream = class
-  FOnData: TGStreamDataEvent;
-  procedure Write(Item: TStreamItem);
-  property OnData: TGStreamDataEvent read FOnData write FOnData;
+  procedure SetSize(AValue: TGStreamIndex);
+  function GetSize: TGStreamIndex;
+  procedure SetPosition(AValue: TGStreamIndex);
+  function GetPosition: TGStreamIndex;
+public
+  procedure Assign(Source: TGStream); virtual;
+  procedure Write(Item: TGStreamItem); virtual; abstract;
+  procedure WriteArray(Item: array of TGStreamItem); virtual; abstract;
+  function Read: TGStreamItem; virtual; abstract;
+  function ReadArray(Count: TGStreamIndex): TGStreamItemArray; virtual; abstract;
+  function Insert(Count: TGStreamIndex): TGStreamIndex; virtual; abstract;
+  function Remove(Count: TGStreamIndex): TGStreamIndex; virtual; abstract;
+  function Seek(Offset: TGStreamIndex; Origin: TSeekOrigin = soCurrent):
+    TGStreamIndex; virtual; abstract;
+  constructor Create; virtual;
+  property Position: TGStreamIndex read GetPosition write SetPosition;
+  property Size: TGStreamIndex read GetSize write SetSize;
 end;
 
@@ -15 +29 @@
 {$IFDEF IMPLEMENTATION}
 
-procedure TGStream.Write(Item: TGStreamItem);
+procedure TGStream.Assign(Source: TGStream);
 begin
-  if Assigned(FOnData) then
-    FOnData(Item);
 end;
 
+procedure TGStream.SetPosition(AValue: TGStreamIndex);
+begin
+  Seek(AValue, soBegin);
+end;
+
+function TGStream.GetPosition: TGStreamIndex;
+begin
+  Result := Seek(0, soCurrent);
+end;
+
+procedure TGStream.SetSize(AValue: TGStreamIndex);
+var
+  StreamSize: TGStreamIndex;
+  OldPosition: TGStreamIndex;
+begin
+  OldPosition := Seek(0, soCurrent);
+  StreamSize := Size;
+  if AValue > StreamSize then begin
+    Seek(StreamSize, soBegin);
+    Insert(AValue - StreamSize);
+  end else
+  if AValue < StreamSize then begin
+    Seek(AValue, soBegin);
+    Remove(StreamSize - AValue);
+  end;
+  Position := OldPosition;
+end;
+
+function TGStream.GetSize: TGStreamIndex;
+var
+  OldPosition: Integer;
+begin
+  OldPosition := Position;
+  Result := Seek(0, soEnd);
+  Position := OldPosition;
+end;
+
+constructor TGStream.Create;
+begin
+  inherited;
+end;
 
 {$UNDEF IMPLEMENTATION}