InterruptExample.scala

object InterruptExample extends App {
  import zio._
  import zio.duration._
  import java.time.LocalTime

  override def run(args: List[String]): URIO[zio.ZEnv, ExitCode] =
    for {
      fiber <- runSomeLongJob
                .ensuring(printWithTime("finalizing job!"))
                .forkDaemon
      _ <- printWithTime("do stuff").repeat(Schedule.spaced(1.seconds) && Schedule.recurs(2))
      _ <- fiber.interrupt
      _ <- printWithTime("do other stuff").repeat(Schedule.spaced(1.seconds))
    } yield ExitCode(0)

  private def runSomeLongJob = {
    printWithTime("long running job...") *> clock.sleep(100.seconds)
  }

  private def printWithTime(msg: String) =
    console.putStrLn(s"${LocalTime.now().toString} $msg")
}