功能性错误处理。执行所有处理程序
Functional error handling. Execute all handlers
我有多个值 F[A]
可能会在完成评估时出现一些错误。如果发生错误,需要执行一些操作。如何为 所有值 执行处理程序,而不仅仅是第一个发生错误的值?
例如
import cats.implicits._
import cats.effect._
class Test[F[_]: Sync] {
def executeAllHandlers[A, B, C](fa: F[A], fb: F[B], fc: F[C]): F[(A, B, C)] =
for {
a <- fa
b <- fb
c <- fc
} yield (a, b, c)
}
object Test extends App{
val ioa: IO[Int] = IO.raiseError(new Error) onError {
case _ => IO(println("ioa"))
}
val iob: IO[String] = IO.raiseError(new Error) onError {
case _ => IO(println("iob"))
}
val ioc: IO[Double] = 2.5.pure[IO]
//prints ioa and fails with Error
new Test[IO].executeAllHandlers(ioa, iob, ioc).unsafeRunSync()
}
我想要实现的是为所有错误的评估执行处理程序,在上面的例子中是 ioa
和 iob
并因错误而失败(无论是哪个)。
有没有可能在猫身上实现这样的目标?也许 mtl
类型类在这里会有帮助?
应用 @LuisMiguelMejíaSuárez
给出的提示是如何修改函数以便执行所有处理程序
def executeAllHandlers[A, B, C](fa: F[A], fb: F[B], fc: F[C]): F[(A, B, C)]=
(for {
a <- fa.attempt
b <- fb.attempt
c <- fc.attempt
} yield for {
a <- a
b <- b
c <- c
} yield (a, b, c)).flatMap(Sync[F].fromEither)
现在它执行了两个处理程序然后抛出 Error
。
ioa
iob
Exception in thread "main" java.lang.Error
我有多个值 F[A]
可能会在完成评估时出现一些错误。如果发生错误,需要执行一些操作。如何为 所有值 执行处理程序,而不仅仅是第一个发生错误的值?
例如
import cats.implicits._
import cats.effect._
class Test[F[_]: Sync] {
def executeAllHandlers[A, B, C](fa: F[A], fb: F[B], fc: F[C]): F[(A, B, C)] =
for {
a <- fa
b <- fb
c <- fc
} yield (a, b, c)
}
object Test extends App{
val ioa: IO[Int] = IO.raiseError(new Error) onError {
case _ => IO(println("ioa"))
}
val iob: IO[String] = IO.raiseError(new Error) onError {
case _ => IO(println("iob"))
}
val ioc: IO[Double] = 2.5.pure[IO]
//prints ioa and fails with Error
new Test[IO].executeAllHandlers(ioa, iob, ioc).unsafeRunSync()
}
我想要实现的是为所有错误的评估执行处理程序,在上面的例子中是 ioa
和 iob
并因错误而失败(无论是哪个)。
有没有可能在猫身上实现这样的目标?也许 mtl
类型类在这里会有帮助?
应用 @LuisMiguelMejíaSuárez
给出的提示是如何修改函数以便执行所有处理程序
def executeAllHandlers[A, B, C](fa: F[A], fb: F[B], fc: F[C]): F[(A, B, C)]=
(for {
a <- fa.attempt
b <- fb.attempt
c <- fc.attempt
} yield for {
a <- a
b <- b
c <- c
} yield (a, b, c)).flatMap(Sync[F].fromEither)
现在它执行了两个处理程序然后抛出 Error
。
ioa
iob
Exception in thread "main" java.lang.Error