renamed the debug method to avoid conflict in cats effect

Author: yadavan88

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)