如何添加适当的错误处理对猫效应的资源

问题描述 投票:4回答:1

我试图让使用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]])?

scala functional-programming scala-cats cats-effect
1个回答
4
投票

适当的错误处理可以通过使用对返回的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))

此外,你可能会感兴趣的qazxsw POI数据类型,其中有qazxsw POI,且形式为ZIO其中supported cats-effect instances捕获错误效果类型的形状稍有不同。

© www.soinside.com 2019 - 2024. All rights reserved.