Raj*_*jan 6 scala scala-cats http4s cats-effect
我有一个使用ciris进行配置管理的 http4s 项目。
该项目是在GitHub上这里。
libraryDependencies ++= Seq(
"is.cir" %% "ciris-cats",
"is.cir" %% "ciris-cats-effect",
"is.cir" %% "ciris-core",
"is.cir" %% "ciris-enumeratum",
"is.cir" %% "ciris-refined"
).map(_ % "0.12.1")
libraryDependencies ++= Seq(
"org.http4s" %% "http4s-dsl",
"org.http4s" %% "http4s-blaze-server"
).map(_ % "0.18.18")
libraryDependencies ++= Seq(
"com.ovoenergy" %% "ciris-kubernetes" % "0.5",
"org.typelevel" %% "kittens" % "1.2.0",
"eu.timepit" %% "refined-cats" % "0.9.3"
)
Run Code Online (Sandbox Code Playgroud)
当我编译我的项目时,这里出现以下错误
[info] Compiling 12 Scala sources to /Users/rajkumar.natarajan/Documents/Coding/OS/ciris-example/target/scala-2.12/classes ...
[error] /Users/rajkumar.natarajan/Documents/Coding/OS/ciris-example/src/main/scala/is/cir/example/application/Http4sApi.scala:24:68: Cannot find an implicit value for ContextShift[cats.effect.IO]:
[error] * import ContextShift[cats.effect.IO] from your effects library
[error] * if using IO, use cats.effect.IOApp or build one with cats.effect.IO.contextShift
[error] implicit val ioConcurrentEffect: Concurrent[IO] = cats.effect.IO.ioConcurrentEffect
[error] ^
[error] /Users/rajkumar.natarajan/Documents/Coding/OS/ciris-example/src/main/scala/is/cir/example/application/Http4sApi.scala:43:69: type mismatch;
[error] found : (ec: scala.concurrent.ExecutionContext, sc: java.util.concurrent.ScheduledExecutorService)cats.effect.Timer[cats.effect.IO] <and> (ec: scala.concurrent.ExecutionContext)cats.effect.Timer[cats.effect.IO]
[error] required: cats.effect.Timer[cats.effect.IO]
[error] Timeout(finite)(service)(ioConcurrentEffect, cats.effect.IO.timer)
[error] ^
Run Code Online (Sandbox Code Playgroud)
究其原因,我错过了需要通过功能隐含参数在这里
的这个错误告诉我使用use cats.effect.IOApp or build one with cats.effect.IO.contextShift,但无法找到cats.effect.IOApp或cats.effect.IO.contextShift
任何帮助表示赞赏。
有几种流行的用法,implicit其中之一是传递一些“上下文”信息。您看到的代码是这种用法的经典示例。
当您执行“超时”时,您需要决定两件事:
这些参数的重要之处在于,一方面它们对工作至关重要,但另一方面它们仅支持主要参数。另一件事是,您可能只想拥有一个(或极少数)全局对象,可以随处使用这些对象。这就是使它们成为上下文的原因,这也是隐式传递它们的原因。
现在您可以选择从何处获取它们:
这个选择不是一个简单的设计决定,取决于你将如何使用你的 API。通常,正确的选择是第一个 - 将它们作为您的上下文。通过这种方式,您允许调用者以它想要的方式设置上下文(例如,应该Timer并Concurrent使用相同的线程池还是不同的线程池?)。有时可以创建自己的独立上下文。或者将您从外部收到的另一个上下文包装成特定于您的内容。
假设您想将外部上下文包装在您的边界处Http4sApi,您可以编写如下代码:
final case class Http4sApi()(implicit executionContext: ExecutionContext) extends HttpApiAlg[IO] {
// create IO-specific context from the executionContext
private implicit val cs = IO.contextShift(executionContext)
private implicit val timer = IO.timer(executionContext)
Run Code Online (Sandbox Code Playgroud)
然后你可以只写
def withTimeout(timeout: Duration)(service: HttpService[IO]): HttpService[IO] = timeout match {
case finite: FiniteDuration => Timeout(finite)(service)
case _ => service
}
Run Code Online (Sandbox Code Playgroud)
它应该编译。