我正在尝试使用 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]]
)?
最佳答案
可以通过使用 .attempt
添加适当的错误处理在返回的 IO 值上:
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 感兴趣数据类型,具有 supported cats-effect instances , 并具有与
IO[E, A]
形式略有不同的形状哪里E
捕获错误效果类型。
关于scala - 如何为 cat-effect 的资源添加正确的错误处理,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/54548901/