如何为 cats-effect 的资源添加正确的错误处理

Question

我正在尝试使用 cats-effect. After following this 教程以纯功能方式获取一些基本文件 IO (write/read)，这是我最终读取文件的结果：

private def readFile(): IO[String] = for {
  lines <-  bufferedReader(new File(filePath)).use(readAllLines)
} yield lines.mkString

def bufferedReader(f: File): Resource[IO, BufferedReader] =
  Resource.make {
    IO(new BufferedReader(new FileReader(f)))
  } { fileReader =>
    IO(fileReader.close()).handleErrorWith(_ => IO.unit)
  }

现在，在 handleErrorWith 函数中，我可以记录发生的任何错误，但是我怎样才能为此添加正确的错误处理（例如 return a Resource[IO, Either[CouldNotReadFileError, BufferedReader]]）？

Answer 1

可以通过对返回的 IO 值使用 .attempt 添加适当的错误处理：

import scala.collection.JavaConverters._

val resourceOrError: IO[Either[Throwable, String]] = bufferedReader(new File(""))
  .use(resource => IO(resource.lines().iterator().asScala.mkString))
  .attempt

如果你想把它提升到你自己的 ADT 中，你可以使用 leftMap:

import cats.syntax.either._

final case class CouldNotReadError(e: Throwable)

val resourceOrError: IO[Either[CouldNotReadError, String]] =
  bufferedReader(new File(""))
    .use(resource => IO(resource.lines().iterator().asScala.mkString))
    .attempt
    .map(_.leftMap(CouldNotReadError))

此外，您可能对 ZIO datatype, which has supported cats-effect instances 感兴趣，并且 IO[E, A] 的形状略有不同，其中 E 捕获错误效果类型。

如何为 cats-effect 的资源添加正确的错误处理

How to add proper error handling to cats-effect's Resource

scala

functional-programming

scala-cats

cats-effect