scala - ZIOスケジュールの簡単な例

Question

ZIO のスケジュールとリトライで遊びたいのですが、完成した例が見つかりません。このコードはどうですか (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