scala - 如何在抽象效果类型上配置猫计时器

Question

假设我在使用 Cats-effect 和无标记 final方法的项目中有以下方法签名:

def schedule[F[_]: Applicative : Async: Timer]

我正在尝试使用纯 FP 在 schedule 方法调用上安排操作。

我这样试过:

Timer[F].sleep(FiniteDuration(10, TimeUnit.SECONDS)) *> {
    Applicative[F].pure(println("tick"))
}

但它没有起作用，因为 effect println("tick") 在 Timer 初始化阶段执行。

如何让它正常工作？

我是否还可以创建某种递归构造，以便每 10 秒重复我的预定操作？

Answer 1

Applicative[F].pure 没有延迟效果。它只会将一个纯值提升到 F 中。由于您有 Async 上下文绑定(bind)，我建议使用 Async[F].delay(println("tick"))。

您可以像这样轻松地递归调用它:

def schedule[F[_]: Async: Timer]: F[Unit]

def repeat[F[_]: Async: Timer]: F[Unit] =
  schedule >> repeat