Merge pull request #21 from ronnygunawan/streaming

Streaming serializing & deserializing

Benchmarks/Program.cs

@@ -91,6 +91,16 @@ public string CsvSerializerV2Serialize() {
 			return Csv.CsvSerializer.Serialize(_data);
 		}
 
+		[Benchmark]
+		public string CsvSerializerStreamingSerialize() {
+			using MemoryStream memoryStream = new();
+			using StreamWriter streamWriter = new(memoryStream, Encoding.UTF8);
+			Csv.CsvSerializer.Serialize(streamWriter, _data);
+			memoryStream.Position = 0;
+			using StreamReader streamReader = new(memoryStream, Encoding.UTF8);
+			return streamReader.ReadToEnd();
+		}
+
 		[Benchmark]
 		public string CsvHelperSerialize() {
 			using MemoryStream memoryStream = new();
@@ -209,21 +219,25 @@ public Model[] CsvSerializerV2Deserialize() {
 		}
 
 		[Benchmark]
-		public List<Model> CsvHelperDeserialize() {
+		public void CsvSerializerStreamingDeserialize() {
+			using MemoryStream memoryStream = new(Encoding.UTF8.GetBytes(_csv));
+			using StreamReader streamReader = new(memoryStream);
+			foreach (Model _ in Csv.CsvSerializer.Deserialize<Model>(streamReader, hasHeaders: true)) { }
+		}
+
+		[Benchmark]
+		public void CsvHelperDeserialize() {
 			using MemoryStream memoryStream = new(Encoding.UTF8.GetBytes(_csv));
 			using StreamReader streamReader = new(memoryStream);
 			using CsvHelper.CsvReader csvReader = new(streamReader, CultureInfo.InvariantCulture);
-			return csvReader.GetRecords<Model>().ToList();
+			foreach (Model _ in csvReader.GetRecords<Model>()) { }
 		}
 
 		[Benchmark]
-		public List<Model> RecordParserRead() {
-			List<Model> items = new();
+		public void RecordParserRead() {
 			foreach (string line in _csv.Split("\r\n").Skip(1)) {
-				Model item = RecordParserReader.Parse(line.AsSpan());
-				items.Add(item);
+				_ = RecordParserReader.Parse(line.AsSpan());
 			}
-			return items;
 		}
 	}
 

CsvSerializer/CsvSerializer.csproj

@@ -15,7 +15,7 @@
     <RepositoryUrl>https://github.com/ronnygunawan/csv-serializer</RepositoryUrl>
     <PackageTags>csv serializer deserializer parser core</PackageTags>
     <Description>Fast CSV to object serializer and deserializer.</Description>
-    <Version>2.0.4</Version>
+    <Version>2.0.5</Version>
     <PackageReleaseNotes></PackageReleaseNotes>
     <EnforceExtendedAnalyzerRules>true</EnforceExtendedAnalyzerRules>
     <IsRoslynComponent>true</IsRoslynComponent>