F # чтение csv по строкам асинхронно с изменяемым объектом

Question

Я читал много сообщений здесь, которые очень помогли мне с моей проблемой, но все мои попытки не принесли плодов.

Услышь мой код:

первая функция (Чтение файла для использования построчно)

let readLines filePath = System.IO.File.ReadLines(filePath) 

Вторая функция (обработка линии) EDIT: ошибка опечатка Я забыл строку строки в моем первый пост

let processLine (line:string) (myobj:MYOBJ) = 
// .... some processing 
myobj // I return the object modified 

Теперь я хотел бы, чтобы обработать файл асинхронно с этим (попытка не работает! но цель объяснить то, что я хотел бы,)

let processAll file = 
async { // some processing 
     let mutable obj = new MYOBJ() 
     readLines file 
     |> Seq.iter (fun l -> let obj = proceesLine l) // I would like to modify the object after each Line 
     } 

Я пробовал использовать ref и! для обработки мутации, но не придумал чистого и ясного решения. Что было бы лучшей практикой кода в этом случае?

ВОЗМОЖНОЕ РЕШЕНИЕ: спасибо за вашу драгоценную помощь, здесь возможно два решения

первого решение:

let readL (file:string) = 
async { 
     let mutable myobj = ref(new MYOBJ()) 
     use sr = new StreamReader(file) 
     while not sr.EndOfStream do 
      let line = sr.ReadLine() 
      myobj := proccesLine line !myobj 
      () 
     sr.Close() 
     } 

второго Solutio: (с использованием CSVReader Library)

let readL (file:string) = 
async { 
     let myobj = new MYOBJ() 
     use sr = new CsvReader(new StreamReader(file),false) 
     let fcount = sr.FieldCount 
     let data : string array = Array.zeroCreate fcount 
     let rec readLinloop (readNext, str:CsvReader, obj:MYOBJ) = 
      match readNext with 
       | false ->() 
       | true -> sr.CopyCurrentRecordPartTo(data,0) 
          let obj = processLine data obj 
          readL(str.ReadNextRecord(), str, obj) 
     readLinLoop(sr.ReadNextRecord(),sr, myobj) 
     sr.Dispose() 
     } 

сейчас , Я все еще хотел знать, возможно ли иметь встроенную функцию, которая возвращает что-то иное, чем тип единицы, используя Seq.iter. Код будет легче читать.

EDIT: третье решение, предложенное iljarn, что решается вопрос

let processAll file = 
    async { (MYOBJ(), readLines file) ||> Seq.fold processLine } 

Answer 1

Это кажется соответствующим потребительной случае для Seq.fold:

let processAll file = 
    async { (MYOBJ(), readLines file) ||> Seq.fold (fun o l -> processLine l o) } 

Обратите внимание, что если вы изменить порядок processLine ' s, то это можно было бы свести к:

let processAll file = 
    async { (MYOBJ(), readLines file) ||> Seq.fold processLine }