小编pra*_*rCS的帖子

我试图使用FileHelpers将csv文件中的行加载到f#中的Elasticsearch数据库以读取csv.一切都适用于小型测试文件,下面的代码片段一次读取所有记录

let readRows<'T>(filePath:string) =
    let engine = FileHelperEngine(typeof<'T>)

    engine.ReadFile(filePath)
    |> Array.map (fun row -> row :?> 'T)

不幸的是,它需要能够读取更大的文件,其中许多列将在以后逐行丢弃.FileHelperAsyncEngine.BeginReadFile函数返回一个IDisposable.

let readRowsAsync<'T>(filePath:string) =
    let engine = new FileHelperAsyncEngine(typeof<'T>)

    engine.BeginReadFile(filePath:string)
    |> ...

如何进一步将此对象处理为<T> s数组？