Applied more optimizations as suggested by David.

Author: goldytech

src/FileIO/WithPipeLines.cs

@@ -105,10 +105,18 @@ private static class LineParser
                         case 3:
                             {
                                 var buffer = line[..comaAt];
-                                if (Utf8Parser.TryParse(buffer, out DateTime value, out var bytesConsumed))
+                                if (DateTime.TryParse(Encoding.UTF8.GetString(line[..comaAt]), out var doj))
+
                                 {
-                                    record.DateOfJoining = value;
+                                    record.DateOfJoining = doj;
                                 }
+                                // Can't use Utf8 parser to extract datetime field because csv format doesn't have time
+                                //https://docs.microsoft.com/en-us/dotnet/api/system.buffers.text.utf8parser.tryparse?view=net-5.0#System_Buffers_Text_Utf8Parser_TryParse_System_ReadOnlySpan_System_Byte__System_DateTime__System_Int32__System_Char_
+
+                                // if (Utf8Parser.TryParse(buffer, out DateTime value, out var bytesConsumed))
+                                // {
+                                //     record.DateOfJoining = value;
+                                // }
                                 break;
                             }
 

tests/FileIO.Benchmarks/FileIOTest.cs

@@ -1,4 +1,5 @@
 using System.Buffers;
+using System.Collections.Generic;
 using System.IO;
 using System.Reflection;
 using System.Threading.Tasks;
@@ -22,7 +23,8 @@ public void Setup()
         [Benchmark]
         public async Task PipeLines()
         {
-           
+           // var directoryPath = Path.GetDirectoryName(Assembly.GetAssembly(typeof(Program))?.Location);
+            //_filePath = Path.Combine(directoryPath ?? string.Empty, "Employees.csv");
             var pool = ArrayPool<Employee>.Shared;
             var employeeRecords = pool.Rent(100000);
             var pipeLinesTest = new WithPipeLines();
@@ -38,17 +40,20 @@ public async Task PipeLines()
         }
 
         [Benchmark]
-        public async Task AsyncStream()
+        public async Task<IList<Employee>> AsyncStream()
         { 
+          //  var directoryPath = Path.GetDirectoryName(Assembly.GetAssembly(typeof(Program))?.Location);
+           // _filePath = Path.Combine(directoryPath ?? string.Empty, "Employees.csv");
             var asyncStream = new WithAsyncStreams();
            var employees = await asyncStream.ProcessStreamAsync(_filePath);
+           return employees;
         }
 
         [Benchmark]
         public void CsvHelper()
         {
-            var directoryPath = Path.GetDirectoryName(Assembly.GetAssembly(typeof(Program))?.Location);
-            _filePath = Path.Combine(directoryPath ?? string.Empty, "Employees.csv");
+          //  var directoryPath = Path.GetDirectoryName(Assembly.GetAssembly(typeof(Program))?.Location);
+            //_filePath = Path.Combine(directoryPath ?? string.Empty, "Employees.csv");
             var csvHelper = new WithCsvHelperLib();
             var employeesList = csvHelper.ProcessFileAsync(_filePath);
 

tests/FileIO.Benchmarks/Program.cs

@@ -11,8 +11,8 @@ static async Task Main(string[] args)
 
          //var test = new FileIOTest();
          //await test.PipeLines();
-         //await test.AsyncStream();
-         //test.CsvHelper();
+        // await test.AsyncStream();
+        // test.CsvHelper();
         }
     }
 }