1

我对猫的效果很陌生,我已经喜欢并享受它了:)

这是关于纤维的

正如我看到的那样,纤维可以被取消,我试图看看是否有可能有一个带有纤维列表的 IO,当任何纤维发生错误时,可以取消其余的纤维(不确定这是否可以用IO 的纯粹性质)

例如:

val job = IO("long processing")

val fibersIO: IO[NonEmptyList[String]] = NonEmptyList
  .of(job, job, job, job)
  .parTraverse(_.start)
  .flatMap(_.parTraverse(_.join))

有可能实现这样的事情吗?

fibersIO.handleErrorWith { error =>
    // cancel contained fibers
}

任何帮助/提示将不胜感激

4

0 回答 0