zio - 将 ZIO 任务转换为 IO

Question

我有下一个代码:

import zio._

import scala.concurrent.Future

case class AppError(description: String) extends Throwable
// legacy-code imitation
def method(x: Int): Task[Boolean] = {
  Task.fromFuture { implicit ec => Future.successful(x == 0) }
}

def handler(input: Int): IO[AppError, Int] = {
  for {
    result <- method(input)
    _ <- IO.fail(AppError("app error")).when(result)
  } yield input
}

但是这段代码不能编译，因为编译器说结果类型是:

ZIO[Any, Throwable, Int]

如何从 Task(我调用 method 的地方)转换为 IO？

Answer 1

您需要决定要如何处理不是 AppError 的 Throwable 错误。

如果您决定要将它们映射到 AppError，您可以执行以下操作:

method(input).mapError {
  case ae: AppError => ae
  case other =>        AppError(other.getMessage)
}

如果你想改进这些错误并且只保留那些 AppError 那么你可以使用 refine* 运算符家族之一，这将保留错误匹配谓词并终止纤程。

method(input).refineToOrDie[AppError] // IO[AppError, Boolean]
// Or
method(input).refineOrDie { case ae: AppError => ae } // IO[AppError, Boolean]

或者如果您想假设所有来自 method 的错误都被认为是“Fiber terminating”，那么您可以使用 .orDie 来吸收错误并终止 fiber:

method(input).orDie // UIO[Boolean]

或者如果你想从错误中恢复并以不同的方式处理它，那么你可以使用 catch* 系列

method(input).catchAll(_ => UIO.succeed(false)) // UIO[Boolean]

最后，如果您希望将结果映射到 Either，您可以使用 .either，这会将错误从错误 channel 中移除并将其映射到 任一[E, A]

method(input).either // UIO[Either[Throwable, Boolean]]

有一个很棒的备忘单(虽然有点过时了)here还有