streams.scala

//> using lib "co.fs2::fs2-core:3.2.4"
//> using lib "org.typelevel::cats-effect:3.3.1"

import cats.effect.{ExitCode, IO, IOApp}
import fs2._


object FunctionalStreams extends IOApp {
  def run(args: List[String]): IO[ExitCode] = (for {
    _ <- IO.pure("a")
    _ <- IO.println("Here")
    s = (for {
      _ <- Stream.emit[IO,Int](1)
      _ <- Stream.empty
    } yield ()).compile
    _ <- if (args.nonEmpty) s.lastOrError else s.lastOrError.start
    _ <- IO.println("Look ma, I skipped the Exception!")
  } yield ()).handleErrorWith(e => IO.println(s"I just recovered from ${e.getClass}"))
  .as(ExitCode.Success)

}