Scalaz Zio Schedule test

ZioScheduleTest.scala

import scalaz.zio._
import scalaz.zio.interop.future._
import scala.concurrent.{ ExecutionContext, Future }
import scala.concurrent.duration._

object ZioScheduleTest extends App {

  var counter = 0

  def futureF(): Future[Int] = {
    counter += 1
    if (counter % 3 == 0) {
      val message = s"failed for $counter"
      println(message)
      Future.failed(new Exception(message))
    } else {
      println(s"success for $counter")
      Future.successful(counter)
    }
  }

  val updateSchedule = Schedule.spaced(10.seconds)
  val retryPolicy = Schedule.fibonacci(1.second) || updateSchedule

  val ioF =
    IO.fromFuture(futureF _)(ExecutionContext.global)
      .repeat(updateSchedule)  // should update every 10 seconds, until it fails
      .retry(retryPolicy)      // keep retrying program above ^, with fibonacci growing intervals, but at most 10 seconds

  // This program will effectively run forever  
  def run(args: List[String]): IO[Nothing, ExitStatus] =
    ioF.attempt.map(_.fold(_ => 1, _ => 0)).map(ExitStatus.ExitNow(_))
}