Merge pull request #554 from yadavan88/cats-effect-upgrade

Updated cats effect to latest and fixed compilation error

Author: lor6

build.sbt

@@ -364,7 +364,7 @@ lazy val scala3_lang_2 = (project in file("scala3-lang-2")).settings(
 lazy val cats_effects = (project in file("cats-effects"))
   .settings(
     name := "cats-effects",
-    libraryDependencies += "org.typelevel" %% "cats-effect" % "3.3.13",
+    libraryDependencies += catsEffect,
     libraryDependencies += "org.typelevel" %% "munit-cats-effect-3" % "1.0.7" % Test,
     libraryDependencies += "junit" % "junit" % "4.13.2" % Test
   )

cats-effects/src/main/scala/com/baeldung/scala/fibers/Fibers.scala

@@ -10,12 +10,12 @@ import scala.util.Random
 object Fibers extends IOApp.Simple {
 
   val sequentialOps =
-    IO("Step1").debug >> IO("Step2").debug >> IO("Step3").debug
+    IO("Step1").printIO >> IO("Step2").printIO >> IO("Step3").printIO
 
   val io: IO[String] =
-    IO("Starting a task").debug >> IO.sleep(400.millis) >> IO(
+    IO("Starting a task").printIO >> IO.sleep(400.millis) >> IO(
       "Task completed"
-    ).debug
+    ).printIO
 
   val fibExec = for {
     fib <- io.start
@@ -24,39 +24,39 @@ object Fibers extends IOApp.Simple {
 
   val fibCancel: IO[Outcome[IO, Throwable, String]] = for {
     fib <- io.start
-    _ <- IO.sleep(100.millis) >> fib.cancel >> IO("Fiber cancelled").debug
+    _ <- IO.sleep(100.millis) >> fib.cancel >> IO("Fiber cancelled").printIO
     res <- fib.join
   } yield res
 
   val outcome: IO[String] = fibCancel.flatMap {
-    case Outcome.Succeeded(fa) => IO("fiber executed successfully").debug
-    case Outcome.Errored(e)    => IO("error occurred during fiber execution").debug
-    case Outcome.Canceled()    => IO("fiber was canceled!").debug
+    case Outcome.Succeeded(fa) => IO("fiber executed successfully").printIO
+    case Outcome.Errored(e)    => IO("error occurred during fiber execution").printIO
+    case Outcome.Canceled()    => IO("fiber was canceled!").printIO
   }
 
   val ioWithCancelationHook =
-    io.onCancel(IO("Applying cancelation finalizer").debug.void)
+    io.onCancel(IO("Applying cancelation finalizer").printIO.void)
   val finaliserAction = for {
     fib <- ioWithCancelationHook.start
-    _ <- IO.sleep(100.millis) >> fib.cancel >> IO("fiber cancelled").debug
+    _ <- IO.sleep(100.millis) >> fib.cancel >> IO("fiber cancelled").printIO
     _ <- fib.join
   } yield ()
 
   val participant1 =
-    IO("Start Task1").debug >> IO.sleep(Random.nextInt(1000).millis) >> IO(
+    IO("Start Task1").printIO >> IO.sleep(Random.nextInt(1000).millis) >> IO(
       "Task 1 completed"
-    ).debug
+    ).printIO
   val participant2 =
-    IO("Start Task2").debug >> IO.sleep(Random.nextInt(1000).millis) >> IO(
+    IO("Start Task2").printIO >> IO.sleep(Random.nextInt(1000).millis) >> IO(
       "Task 2 completed"
-    ).debug
+    ).printIO
   val raceResult: IO[Either[String, String]] =
     IO.race(participant1, participant2)
 
   val participant1WithFinaliser =
-    participant1.onCancel(IO("Task 1 got canceled").debug.void)
+    participant1.onCancel(IO("Task 1 got canceled").printIO.void)
   val participant2WithFinaliser =
-    participant2.onCancel(IO("Task 2 got canceled").debug.void)
+    participant2.onCancel(IO("Task 2 got canceled").printIO.void)
   val raceWithFinaliser =
     IO.race(participant1WithFinaliser, participant2WithFinaliser)
 
@@ -67,7 +67,7 @@ object Fibers extends IOApp.Simple {
 
   val ioWithTimeout: IO[String] = participant1.timeout(400.millis)
 
-  val ioWithFallback = participant1.timeoutTo(400.millis, IO("Fallback IO executed after timeout").debug)
+  val ioWithFallback = participant1.timeoutTo(400.millis, IO("Fallback IO executed after timeout").printIO)
 
   override def run: IO[Unit] = ioWithFallback.void
 }

cats-effects/src/main/scala/com/baeldung/scala/fibers/IOExtensions.scala

@@ -4,7 +4,7 @@ import cats.effect.IO
 
 object IOExtensions {
   implicit class Xtensions[A](io: IO[A]) {
-    def debug: IO[A] =
+    def printIO: IO[A] =
       for {
         a <- io
         _ = println(s"[${Thread.currentThread().getName}] " + a)

cats-effects/src/test/scala/com/baeldung/scala/fibers/FibersUnitTest.scala

@@ -15,7 +15,7 @@ class FibersUnitTest extends CatsEffectSuite {
   test("Fiber should be canceled") {
     val fibCancel: IO[Outcome[IO, Throwable, String]] = for {
       fib <- io.start
-      _ <- IO.sleep(100.millis) >> fib.cancel >> IO("Fiber cancelled").debug
+      _ <- IO.sleep(100.millis) >> fib.cancel >> IO("Fiber cancelled").printIO
       res <- fib.join
     } yield res