done

leandromoh · Oct 15, 2023 · a880a3a · a880a3a
1 parent e9e621e
commit a880a3a
Show file tree

Hide file tree

Showing 8 changed files with 25 additions and 25 deletions.
diff --git a/RecordParser.Benchmark/FixedLengthReaderBenchmark.cs b/RecordParser.Benchmark/FixedLengthReaderBenchmark.cs
@@ -98,7 +98,7 @@ public void Read_FixedLength_RecordParser_Parallel(bool parallel)
                 Parser = parser.Parse,
             };
 
-            var items = streamReader.GetRecords(readOptions);
+            var items = streamReader.ReadRecords(readOptions);
 
             var i = 0;
             foreach (var person in items)
@@ -127,7 +127,7 @@ public void Read_FixedLength_RecordParser_GetLines()
             using var fileStream = File.OpenRead(PathSampleDataTXT);
             using var streamReader = new StreamReader(fileStream, Encoding.UTF8, true, BufferSize);
 
-            var lines = streamReader.GetRecords();
+            var lines = streamReader.ReadRecords();
 
             var i = 0;
             foreach (var line in lines)

diff --git a/RecordParser.Benchmark/VariableLengthReaderBenchmark.cs b/RecordParser.Benchmark/VariableLengthReaderBenchmark.cs
@@ -108,7 +108,7 @@ public void Read_VariableLength_FullQuoted_RecordParser_Parallel(bool parallel,
                 ContainsQuotedFields = quoted,
             };
 
-            var items = streamReader.GetRecords(parser, readOptions);
+            var items = streamReader.ReadRecords(parser, readOptions);
 
             var i = 0;
             foreach (var person in items)
@@ -151,7 +151,7 @@ public void Read_VariableLength_RecordParser_Parallel(bool parallel, bool quoted
                 ContainsQuotedFields = quoted,
             };
 
-            var items = streamReader.GetRecords(parser, readOptions);
+            var items = streamReader.ReadRecords(parser, readOptions);
 
             var i = 0;
             foreach (var person in items)
@@ -184,7 +184,7 @@ public void Read_VariableLength_RecordParser_Raw(bool parallel, bool quoted)
                 StringPoolFactory = () => new InternPool().Intern
             };
 
-            var items = streamReader.GetRecordsRaw(readOptions, PersonFactory);
+            var items = streamReader.ReadRecordsRaw(readOptions, PersonFactory);
 
             var i = 0;
             foreach (var person in items)

diff --git a/RecordParser.Test/FileReaderTest.cs b/RecordParser.Test/FileReaderTest.cs
@@ -115,7 +115,7 @@ public void Read_csv_file_all_fields_quoted(string fileContent, bool hasHeader,
 
             // Act
 
-            var items = streamReader.GetRecords(parser, readOptions);
+            var items = streamReader.ReadRecords(parser, readOptions);
 
             // Assert
 
@@ -157,7 +157,7 @@ public void Read_quoted_csv_file(string fileContent, bool hasHeader, bool parall
 
             // Act
 
-            var items = streamReader.GetRecords(parser, readOptions);
+            var items = streamReader.ReadRecords(parser, readOptions);
 
             // Assert
 
@@ -247,7 +247,7 @@ public void Read_not_quoted_csv_file(string fileContent, bool hasHeader, bool pa
 
             // Act
 
-            var items = streamReader.GetRecords(parser, readOptions);
+            var items = streamReader.ReadRecords(parser, readOptions);
 
             // Assert
 
@@ -354,7 +354,7 @@ public void Read_fixed_length_file(string fileContent, bool parallelProcessing,
 
             // Act
 
-            var records = streamReader.GetRecords(readOptions);
+            var records = streamReader.ReadRecords(readOptions);
 
             var linesByType = records.ToLookup(x => x.GetType());
             var result = linesByType[typeof(HeaderFixedLength)].Cast<HeaderFixedLength>().Single();
@@ -410,7 +410,7 @@ public void Read_plain_text_of_fixed_length_file(string fileContent, bool parall
 
             var result = new List<string>();
 
-            foreach (var item in streamReader.GetRecords())
+            foreach (var item in streamReader.ReadRecords())
             {
                 result.Add(item.Span.ToString());
             }

diff --git a/RecordParser.Test/FileWriterTest.cs b/RecordParser.Test/FileWriterTest.cs
@@ -85,7 +85,7 @@ public void Write_csv_file(int repeat, bool parallel, bool ordered)
                 ParallelismOptions = new() { Enabled = parallel }
             };
 
-            var reads = textReader.GetRecords(reader, readOptions);
+            var reads = textReader.ReadRecords(reader, readOptions);
 
             reads.Should().BeEquivalentTo(expectedItems);
         }
@@ -140,7 +140,7 @@ public void Write_fixed_length_file(int repeat, bool parallel, bool ordered)
                 ParallelismOptions = new() { Enabled = parallel }
             };
 
-            var reads = textReader.GetRecords(readOptions);
+            var reads = textReader.ReadRecords(readOptions);
 
             reads.Should().BeEquivalentTo(expectedItems);
         }

diff --git a/RecordParser/Extensions/FileReader/FixedLengthReaderExtensions.cs b/RecordParser/Extensions/FileReader/FixedLengthReaderExtensions.cs
@@ -32,16 +32,16 @@ public static class FixedLengthReaderExtensions
         /// <returns>
         /// Sequence of records.
         /// </returns>
-        public static IEnumerable<T> GetRecords<T>(this TextReader reader, FixedLengthReaderOptions<T> options)
+        public static IEnumerable<T> ReadRecords<T>(this TextReader reader, FixedLengthReaderOptions<T> options)
         {
             var func = () => new RowByLine(reader, Length);
             var parser = (ReadOnlyMemory<char> memory, int i) => options.Parser(memory.Span);
             var parallelOptions = options.ParallelismOptions ?? new();
 
             return
                 parallelOptions.Enabled
-                ? GetRecordsParallel(parser, func, HasHeader, parallelOptions)
-                : GetRecordsSequential(parser, func, HasHeader);
+                ? ReadRecordsParallel(parser, func, HasHeader, parallelOptions)
+                : ReadRecordsSequential(parser, func, HasHeader);
         }
 
         /// <summary>
@@ -57,9 +57,9 @@ public static IEnumerable<T> GetRecords<T>(this TextReader reader, FixedLengthRe
         /// Store ReadOnlyMemory values will not hold record's values since the content of the buffer changes
         /// as it goes forward through the file.
         /// </remarks>
-        public static IEnumerable<ReadOnlyMemory<char>> GetRecords(this TextReader reader)
+        public static IEnumerable<ReadOnlyMemory<char>> ReadRecords(this TextReader reader)
         {
-            return GetRecordsSequential((memory, i) => memory, () => new RowByLine(reader, Length), HasHeader);
+            return ReadRecordsSequential((memory, i) => memory, () => new RowByLine(reader, Length), HasHeader);
         }
     }
 }
diff --git a/RecordParser/Extensions/FileReader/ReaderCommon.cs b/RecordParser/Extensions/FileReader/ReaderCommon.cs
@@ -60,7 +60,7 @@ public static ParallelQuery<T> AsParallel<T>(this IEnumerable<T> source, Paralle
             return query;
         }
 
-        public static IEnumerable<T> GetRecordsParallel<T>(
+        public static IEnumerable<T> ReadRecordsParallel<T>(
             Func<ReadOnlyMemory<char>, int, T> reader,
             Func<IFL> getItems,
             bool hasHeader,
@@ -87,7 +87,7 @@ public static IEnumerable<T> GetRecordsParallel<T>(
             }
         }
 
-        public static IEnumerable<T> GetRecordsSequential<T>(Func<ReadOnlyMemory<char>, int, T> reader, Func<IFL> getItems, bool hasHeader)
+        public static IEnumerable<T> ReadRecordsSequential<T>(Func<ReadOnlyMemory<char>, int, T> reader, Func<IFL> getItems, bool hasHeader)
         {
             using var items = getItems();
 

diff --git a/RecordParser/Extensions/FileReader/VariableLengthReaderExtensions.cs b/RecordParser/Extensions/FileReader/VariableLengthReaderExtensions.cs
@@ -40,7 +40,7 @@ public static class VariableLengthReaderExtensions
         /// <returns>
         /// Sequence of records.
         /// </returns>
-        public static IEnumerable<T> GetRecords<T>(this TextReader reader, IVariableLengthReader<T> parser, VariableLengthReaderOptions options)
+        public static IEnumerable<T> ReadRecords<T>(this TextReader reader, IVariableLengthReader<T> parser, VariableLengthReaderOptions options)
         {
             Func<IFL> func = options.ContainsQuotedFields
                             ? () => new RowByQuote(reader, Length, parser.Separator)
@@ -50,8 +50,8 @@ public static IEnumerable<T> GetRecords<T>(this TextReader reader, IVariableLeng
             var parallelOptions = options.ParallelismOptions ?? new();
 
             return parallelOptions.Enabled
-                ? GetRecordsParallel(selector, func, options.HasHeader, parallelOptions)
-                : GetRecordsSequential(selector, func, options.HasHeader);
+                ? ReadRecordsParallel(selector, func, options.HasHeader, parallelOptions)
+                : ReadRecordsSequential(selector, func, options.HasHeader);
         }
     }
 }
diff --git a/RecordParser/Extensions/FileReader/VariableLengthReaderRawExtensions.cs b/RecordParser/Extensions/FileReader/VariableLengthReaderRawExtensions.cs
@@ -103,7 +103,7 @@ private static Get BuildRaw(int collumnCount, bool hasTransform, bool trim)
         /// <returns>
         /// Sequence of records.
         /// </returns>
-        public static IEnumerable<T> GetRecordsRaw<T>(this TextReader reader, VariableLengthReaderRawOptions options, Func<Func<int, string>, T> parser)
+        public static IEnumerable<T> ReadRecordsRaw<T>(this TextReader reader, VariableLengthReaderRawOptions options, Func<Func<int, string>, T> parser)
         {
             var get = BuildRaw(options.ColumnCount, options.StringPoolFactory != null, options.Trim);
             var sep = options.Separator.ToString();
@@ -124,7 +124,7 @@ IEnumerable<T> GetSequential()
                 var stringCache = options.StringPoolFactory?.Invoke();
                 var getField = (int i) => buffer[i];
 
-                return GetRecordsSequential(Parser, func, options.HasHeader);
+                return ReadRecordsSequential(Parser, func, options.HasHeader);
 
                 T Parser(ReadOnlyMemory<char> memory, int i)
                 {
@@ -163,7 +163,7 @@ IEnumerable<T> GetParallel()
                         })
                         .ToArray();
 
-                return GetRecordsParallel(Parser, func, options.HasHeader, parallelOptions);
+                return ReadRecordsParallel(Parser, func, options.HasHeader, parallelOptions);
 
                 T Parser(ReadOnlyMemory<char> memory, int i)
                 {