我有一个异步 http4s 客户端,在运行一些请求后,我从中获得了一组结果。我想检查Seq[Task[Response]]
所有对象的此集合 (a) 是否已完成Task
,并且Response
对象是否处于特定状态。
如果我使用Future
而不是任务,我会做类似的事情
val results: Seq[Future[Response]] = ...
Future.sequence(results).map(_.forall(_.customFunction.isSuccess))
fs2.Task
有没有办法使用代替来实现类似的功能?在我有限的理解中,我假设在某些时候我将不得不调用unsafeRun
,这将阻塞Task
集合中的每个。