fixed typo and used ArrayBufferWriter on test

j0nimost · Oct 28, 2023 · 7044fc7 · 7044fc7
1 parent 48dd134
commit 7044fc7
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 11 deletions.
diff --git a/README.md b/README.md
@@ -104,10 +104,10 @@ Behind the curtains Kafa is using `KafaPooledWriter` a pooled IBufferWriter to w
 `Write<T>(IBufferWriter<byte> bufferWriter, List<T> entities, KafaOptions options = null)` Method.
 
 ```c#
-            var csvs = new List<CSVDataWithAttributes>()
+            var csvs = new List<CsvData>()
             {
-                new CSVDataWithAttributes{ Date = DateTime.Parse("10/10/2023 4:08:38 PM"), Open=12.45, Close=12.99, High=13.00, Low=12.1, Name="AMZN", Volume=1233435512},
-                new CSVDataWithAttributes{ Date = DateTime.Parse("10/10/2023 4:08:38 PM"), Open=12.45, Close=12.99, High=13.00, Low=12.1, Name="AMZN", Volume=1233435512}
+                new CsvData{ Date = DateTime.Parse("10/10/2023 4:08:38 PM"), Open=12.45, Close=12.99, High=13.00, Low=12.1, Name="AMZN", Volume=1233435512},
+                new CsvData{ Date = DateTime.Parse("10/10/2023 4:08:38 PM"), Open=12.45, Close=12.99, High=13.00, Low=12.1, Name="AMZN", Volume=1233435512}
             };
 
             // get a ReadOnlySpan<bytes>
@@ -122,9 +122,9 @@ Behind the curtains Kafa is using `KafaPooledWriter` a pooled IBufferWriter to w
             // or 
             // Write to a IBufferWriter<byte> for zero allocation writes
 
-            using var pooledWriter = new KafaPooledWriter();
-            Kafa.Write<CsvData>(pooledWriter, csvs);
-            var str = Encoding.UTF8.GetString(pooledWriter.WrittenAsSpan);
+            var arrayWriter = new ArrayBufferWriter<byte>();
+            Kafa.Write<CsvData>(arrayWriter, csvs);
+            var str = Encoding.UTF8.GetString(arrayWriter.WrittenSpan);
 
             // or
             // write directly to a file

diff --git a/src/KafaTests/KafaWriteTests.cs b/src/KafaTests/KafaWriteTests.cs
@@ -1,4 +1,5 @@
-using nyingi.Kafa.Writer;
+using System.Buffers;
+using nyingi.Kafa.Writer;
 
 namespace KafaTests
 {
@@ -112,10 +113,10 @@ public async Task WriteToBufferWriter()
             {
                 expected = "Date,Open,High,Low,Close,Volume,Name\r\n10/10/2023 4:08:38 PM,12.45,13,12.1,12.99,1233435512,AMZN\r\n10/10/2023 4:08:38 PM,12.45,13,12.1,12.99,1233435512,AMZN\r\n";
             }
-            
-            using var pooledWriter = new KafaPooledWriter();
-            Kafa.Write<CsvData>(pooledWriter, csvs);
-            var str = Encoding.UTF8.GetString(pooledWriter.WrittenAsSpan);
+
+            var arrayWriter = new ArrayBufferWriter<byte>();
+            Kafa.Write<CsvData>(arrayWriter, csvs);
+            var str = Encoding.UTF8.GetString(arrayWriter.WrittenSpan);
             Assert.Equal(expected, str);
         }
     }