将F# Async<Async<MyTpe>[]>转换为Async<MyType>[]

Question

我从一个HTTP调用中获得了一些数据列表。然后，我知道要为另一个HTTP调用获取什么值。我希望所有的东西都是异步的。但我需要在Expecto's testCaseAsync : string -> Async<unit> -> Test中使用这些数据。所以，我的目标是得到一个像So Async<Item>[]这样的签名

所以，我想要一份testCaseAsync的列表。

所以，我基本上有这样的东西：

// Async<Async<Item>[]>
let getAsyncCalls =
   async {
       let! table = API.getTable ()
       // Async<Item>[]
       let items =
           table.root
           |> Array.map (fun x -> API.getItem x.id)
       return item
   }

如果我并行运行它们，我会得到：

// Async<Item[]>
let getAsyncCalls =
   async {
       let! table = API.getTable ()
       // Item[]
       let! items =
           table.root
           |> Array.map (fun x -> API.getItem x.id)
       return item
   }

所以这并不能让我找到Async<Item>[]。我不确定这是否可能。我希望在API.getTable调用中避免使用Async.RunSynchronously，因为这会导致死锁，对吧？它很可能是从缓存值(memoized)中调用的，所以我不确定这会有什么不同。

我想我会继续努力，除非其他人比我更聪明:-)提前谢谢！

Answer 1

通常，您不能将Async<Async<T>[]>转换为Async<T>[]。问题是，即使要获得数组的长度，您也需要异步执行一些操作，因此无法将数组“提升”到异步之外。如果你事先知道数组的长度，那么你就可以做到这一点。

下面的函数将Async<'T[]>转换为Async<'T>[]，前提是您提供了数组的长度。正如您所了解的，返回的异步需要以某种方式共享对一个顶级异步的访问。我能想到的最简单的方法就是使用任务。让它适应你的用例应该很容易：

let unwrapAsyncArray (asyncs:Async<'T[]>) len = 
  let task = asyncs |> Async.StartAsTask
  Array.init len (fun i -> async {
    let! res = Async.AwaitTask task
    if res.Length <> len then failwith "Wrong length!"
    return res.[i] }  
  )