CsvHelper - Чтение Потока Асинхронно

У меня есть служба, которая принимает входной поток, содержащий CSV-данные, которые должны быть массово вставлены в базу данных, и мое приложение использует async/await везде, где это возможно.

Процесс таков: проанализируйте поток с помощью CsvParser CsvHelper, добавьте каждую строку в DataTable, используйте SqlBulkCopy для копирования DataTable в базу данных.

Данные могут быть любого размера, поэтому я хотел бы избежать чтения всего этого в память за один раз-очевидно, что у меня будут все эти данные в DataTable конец в любом случае так бы по существу иметь 2 копии в памяти.

Я хотел бы сделать все это как можно асинхроннее, но CsvHelper не имеет асинхронных методов, поэтому я придумал следующий обходной путь:

using (var inputStreamReader = new StreamReader(inputStream))

{

    while (!inputStreamReader.EndOfStream)

    {

        // Read line from the input stream

        string line = await inputStreamReader.ReadLineAsync();



        using (var memoryStream = new MemoryStream())

        using (var streamWriter = new StreamWriter(memoryStream))

        using (var memoryStreamReader = new StreamReader(memoryStream))

        using (var csvParser = new CsvParser(memoryStreamReader))

        {

            await streamWriter.WriteLineAsync(line);

            await streamWriter.FlushAsync();



            memoryStream.Position = 0;



            // Loop through all the rows (should only be one as we only read a single line...)

            while (true)

            {

                var row = csvParser.Read();



                // No more rows to process

                if (row == null)

                {

                    break;

                }



                // Add row to DataTable

            }

        }

    }

}

Есть ли какие-либо проблемы с этим решением? Это вообще необходимо? Я видел, что разработчики CsvHelper специально не добавили асинхронную функциональность (https://github.com/JoshClose/CsvHelper/issues/202 ) но я действительно не следую рассуждениям, стоящим за не делающий так.

EDIT: я только что понял, что это решение не будет работать для тех случаев, когда столбец содержит разрыв строки в любом случае : (думаю, мне просто придется скопировать весь входной поток в поток памяти или что-то еще

EDIT2: еще немного информации.

Это асинхронный метод в библиотеке,где я пытаюсь выполнить асинхронность полностью. Скорее всего, он будет потребляться контроллером MVC (если бы я просто хотел выгрузить его из потока пользовательского интерфейса, я бы просто поставил задачу.Запустить его). В основном метод будет ждать на внешних источниках, таких как database / DFS, и я хотел бы, чтобы поток был освобожден, пока он есть.

CsvParser.Read() будет блокировать, даже если блокирует чтение потока (например, если данные, которые я пытаюсь прочитать, находятся на сервере на другой стороне мира), тогда как если CsvHelper реализует асинхронный метод, который использует TextReader.ReadAsync (), то я не буду заблокирован в ожидании прибытия моих данных из Дубая. Насколько я могу скажите, Я не прошу асинхронную оболочку вокруг синхронного метода.