confessions

confessions.scala

package puppyz

import zio._
import zio.ZIO.log
import zio.Duration

object confessions extends ZIOAppDefault {

  def confessLove: UIO[Unit] =
    ZIO.uninterruptibleMask { restore =>
      for {
        _ <- log("🎙️ Recording: 'No one can stop our love...'")
        _ <- restore(ZIO.sleep(7.seconds)) //we simulate delay here so we can interrupt - we're interruptable for 7s
          .onInterrupt(log("💔 Message deleted before sending."))
        _ <- log("📤 Sent! The hearts have been delivered.")
      } yield ()
    }

  override def run: ZIO[Any with ZIOAppArgs with Scope, Any, Any] =
    for {
      fiber <- confessLove.fork
      _     <- ZIO.sleep(2.seconds) // Wait a bit before interrupting(we interrupt before 7 seconds are up, play here)
      _     <- log("🛑 Parent opened the door.")
      _     <- fiber.interrupt
      _     <- fiber.join // Observe what happened
    } yield ()

//    override def run: ZIO[Any with ZIOAppArgs with Scope, Any, Any] =
//      for {
//        fiber <- confessLove.fork
//        _     <- ZIO.sleep(10.seconds) // Wait a bit before interrupting(we interrupt before 7 seconds are up, play here)
//        _     <- log("🛑 Parent opened the door but still sent.")
//        _     <- fiber.interrupt
//        _     <- fiber.join // Observe what happened
//      } yield ()
}