interrupt.scala

//> using scala 3.4.2
//> using toolkit typelevel::latest

import cats.effect.{IO, IOApp}
import cats.effect.std.Random
import fs2.concurrent.SignallingRef
import scala.concurrent.duration.*

object Main extends IOApp.Simple:

    def thingToDo: IO[Boolean] =
        for
            random <- Random.scalaUtilRandom[IO]
            n <- random.betweenInt(0, 100)
            _ <- IO.println(s"Extracted $n")
        yield n < 9

    def run: IO[Unit] = SignallingRef[IO].of[Boolean](false).flatMap: signal =>
        fs2.Stream
          .repeatEval(thingToDo.flatMap(signal.set))
          .meteredStartImmediately(1.second)
          .interruptWhen(signal)
          .interruptAfter(1.hour)
          .compile.drain