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

Question

我正在尝试使用cats-effect以一种纯功能的方式获取一些基本的文件IO (读/写)。在阅读完this教程之后，下面是我在阅读文件时得到的结论：

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函数中，我可以记录任何发生的错误，但是我如何添加适当的错误处理(例如返回一个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))

此外，您可能会对具有supported cats-effect instances的ZIO数据类型感兴趣，它的形式与IO[E, A]略有不同，其中E捕获错误影响类型。