Skip to content

Commit 0b392ee

Browse files
committed
Fix stream reader params and CopyToAsync
1 parent ececefa commit 0b392ee

File tree

3 files changed

+5
-3
lines changed

3 files changed

+5
-3
lines changed

Source/FikaAmazonAPI/ReportGeneration/ReportDataTable/Table.cs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,8 @@ public static Table ConvertFromCSV(string path, char separator = '\t', Encoding
6161

6262
public static Table ConvertFromCSV(Stream stream, char separator = '\t', Encoding encoding = default)
6363
{
64-
using var reader = new StreamReader(stream, encoding ?? Encoding.UTF8, leaveOpen: true);
64+
using var reader = new StreamReader(stream, encoding ?? Encoding.UTF8,
65+
detectEncodingFromByteOrderMarks: true, bufferSize: 1024, leaveOpen: true);
6566
var lines = new List<string>();
6667
while (!reader.EndOfStream)
6768
lines.Add(reader.ReadLine());

Source/FikaAmazonAPI/ReportGeneration/ReportParser.cs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,8 @@ internal static List<T> ParseCsvLines<T>(Stream stream, Func<string, string, T>
4747
return new List<T>();
4848

4949
stream.Position = 0;
50-
using var reader = new StreamReader(stream, encoding ?? Encoding.UTF8, leaveOpen: true);
50+
using var reader = new StreamReader(stream, encoding ?? Encoding.UTF8,
51+
detectEncodingFromByteOrderMarks: true, bufferSize: 1024, leaveOpen: true);
5152
var lines = new List<string>();
5253
while (!reader.EndOfStream)
5354
lines.Add(reader.ReadLine());

Source/FikaAmazonAPI/Services/ReportService.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -303,7 +303,7 @@ private async Task<MemoryStream> GetFileStreamAsync(ReportDocument reportDocumen
303303
stream = new GZipStream(stream, CompressionMode.Decompress);
304304

305305
var memoryStream = new MemoryStream();
306-
await stream.CopyToAsync(memoryStream, cancellationToken);
306+
await stream.CopyToAsync(memoryStream, 81920, cancellationToken);
307307
memoryStream.Position = 0;
308308

309309
return memoryStream;

0 commit comments

Comments
 (0)