Простой пример ZIO Schedule

Question

Я хочу поиграть с ZIO Schedule and Retry и не могу найти готовых примеров. Что насчет этого кода (Мастерская в IDEA):

import zio._
import zio.duration._
import zio.console._

val r = scala.util.Random

def funcReadFromDb(inp :Int): Task[Seq[Int]]= {
  val rnd :Int = r.nextInt(10)
  println(s"rnd=$rnd")
  //if (rnd <= 5)
    Task.succeed(Seq(inp, inp * 2, inp * 3))
  //else Task.fail(new Exception("custom exception"))
}

val spaced :zio.Schedule[zio.clock.Clock with Console,Any,Int] = Schedule.spaced(1.second)

val schedEff = for {
  s <- funcReadFromDb(3).repeat(spaced)
  _ <- putStrLn(s"s=$s")
} yield ()

val runtime = new DefaultRuntime {}
runtime.unsafeRun(schedEff)

Я ожидаю некоторого итеративного вывода с интервалом 1 сек. И вывести:

spaced: zio.Schedule[zio.clock.Clock with zio.console.Console,Any,Int] = zio.Schedule$$anon$18@535bf6e0

rnd=4
schedEff: zio.ZIO[zio.clock.Clock with zio.console.Console,Throwable,Unit] = zio.ZIO$FlatMap@63303dbf

runtime: zio.DefaultRuntime = $anon$1@3e661711

Answer 1

funcReadFromDb не чисто. nextInt а также println являются эффектами и должны быть заключены в Task тело.

def funcReadFromDb(inp :Int): Task[Seq[Int]]= {
    Task.effect {
      val rnd: Int = r.nextInt(10)
      println(s"rnd=$rnd")
      Seq(inp, inp * 2, inp * 3)
    }
}