异步解压缩gzip文件

Question

作为F＃培训，我试图解压gzip文件。这是我写的代码：

let decompress (inputStream: Stream) (outputStream : Stream) = async { 
    use gs = new GZipStream(inputStream, CompressionMode.Decompress) 
    let buffer = Array.zeroCreate<byte> 4096 

    let rec decompressInternal() = async { 
     let! read = gs.ReadAsync(buffer, 0, buffer.Length) |> Async.AwaitTask 
     match read with 
     | 0 -> 
      inputStream.Dispose() 
      return() 
     | _ -> 
      do! outputStream.WriteAsync(buffer, 0, read) |> Async.AwaitTask |> Async.Ignore 
      return! decompressInternal() 
    } 

    return! decompressInternal() 
} 

我也写一个单元测试，它失败的时刻（我得到一个空字符串，如果解压缩操作后出现的断言）：

[<Fact>] 
let ``Decompress a gzipped file``() = 
    use fs = new FileStream("Input/test.txt.gz", FileMode.Open) 
    use ms = new MemoryStream() 
    decompress fs ms |> Async.RunSynchronously 
    use sr = new StreamReader(ms) 
    Assert.Equal ("This is a test", sr.ReadToEnd()) 

我认为我错过了F＃async capablib的一个，但我看不到我的错误...

Answer 1

您对Async的使用非常好。你只有一个MemoryStream，其位置仍然在写入之后，所以没有任何可读的。在创建StreamReader之前，请使用以下方法来重置位置，它将起作用：

ms.Seek(0L, SeekOrigin.Begin) |> ignore