Changeset 405 for CoolStreaming

Timestamp:

Aug 14, 2012, 7:04:04 AM (12 years ago)

Author:

chronos

Message:

• Modified: TemplateGenerics TBinarySerializer now use TListByte class instead TStreamByte.

Location:

CoolStreaming

Files:

• CoolStreaming.lpk (modified) (1 diff)
• UVarBlockSerializer.pas (modified) (6 diffs)

CoolStreaming/CoolStreaming.lpk

@@ -50 +50 @@
     </Files>
     <Type Value="RunAndDesignTime"/>
-    <RequiredPkgs Count="3">
+    <RequiredPkgs Count="2">
       <Item1>
         <PackageName Value="Common"/>
       </Item1>
       <Item2>
-        <PackageName Value="TemplateGenerics"/>
-      </Item2>
-      <Item3>
         <PackageName Value="FCL"/>
         <MinVersion Major="1" Valid="True"/>
-      </Item3>
+      </Item2>
     </RequiredPkgs>
     <UsageOptions>

CoolStreaming/UVarBlockSerializer.pas

@@ -38 +38 @@
     procedure WriteVarStream(AStream: TStream);
     procedure ReadVarStream(AStream: TStream);
+    procedure WriteVarList(List: TListByte);
+    procedure ReadVarList(List: TListByte);
     function GetVarSize: Integer;
     function GetVarCount: Integer;
@@ -80 +82 @@
     procedure WriteVarStream(Index: Integer; Stream: TStream);
     procedure ReadVarStream(Index: Integer; Stream: TStream);
+    procedure WriteVarList(Index: Integer; List: TListByte);
+    procedure ReadVarList(Index: Integer; List: TListByte);
     procedure WriteVarIndexedBlock(Index: Integer; Block: TVarBlockIndexed);
     procedure ReadVarIndexedBlock(Index: Integer; Block: TVarBlockIndexed);
@@ -101 +105 @@
     procedure WriteToStream(Stream: TStream);
     procedure ReadFromStream(Stream: TStream);
+    procedure WriteToList(List: TListByte);
+    procedure ReadFromList(List: TListByte);
     constructor Create;
     destructor Destroy; override;
@@ -413 +419 @@
 end;
 
+procedure TVarBlockSerializer.WriteVarList(List: TListByte);
+var
+  Mem: TMemoryStream;
+begin
+  try
+    Mem := TMemoryStream.Create;
+    List.WriteToStream(Mem);
+    WriteVarStream(Mem);
+  finally
+    Mem.Free
+  end;
+end;
+
+procedure TVarBlockSerializer.ReadVarList(List: TListByte);
+var
+  Mem: TMemoryStream;
+begin
+  try
+    Mem := TMemoryStream.Create;
+    ReadVarStream(Mem);
+    List.Count := Mem.Size;
+    List.ReplaceStream(Mem);
+  finally
+    Mem.Free
+  end;
+end;
+
 function TVarBlockSerializer.GetVarSize: Integer;
 var
@@ -697 +730 @@
 end;
 
+procedure TVarBlockIndexed.WriteVarList(Index: Integer; List: TListByte);
+begin
+  CheckItem(Index);
+  TVarBlockSerializer(Items[Index]).WriteVarList(List);
+end;
+
+procedure TVarBlockIndexed.ReadVarList(Index: Integer; List: TListByte);
+begin
+  TVarBlockSerializer(Items[Index]).ReadVarList(List);
+end;
+
 procedure TVarBlockIndexed.WriteVarIndexedBlock(Index: Integer;
   Block: TVarBlockIndexed);
@@ -915 +959 @@
 end;
 
+procedure TVarBlockIndexed.WriteToList(List: TListByte);
+var
+  Mem: TMemoryStream;
+begin
+  try
+    Mem := TMemoryStream.Create;
+    WriteToStream(Mem);
+    List.Count := Mem.Size;
+    List.ReplaceStream(Mem);
+  finally
+    Mem.Free;
+  end;
+end;
+
+procedure TVarBlockIndexed.ReadFromList(List: TListByte);
+var
+  Mem: TMemoryStream;
+begin
+  try
+    Mem := TMemoryStream.Create;
+    List.WriteToStream(Mem);
+    ReadFromStream(Mem);
+  finally
+    Mem.Free;
+  end;
+end;
+
 constructor TVarBlockIndexed.Create;
 begin