diff --git a/modules/effects/src/main/scala/dev/profunktor/redis4cats/transactions.scala b/modules/effects/src/main/scala/dev/profunktor/redis4cats/transactions.scala index 9e87a324..f6b258cc 100644 --- a/modules/effects/src/main/scala/dev/profunktor/redis4cats/transactions.scala +++ b/modules/effects/src/main/scala/dev/profunktor/redis4cats/transactions.scala @@ -60,12 +60,11 @@ object transactions { ys match { case HNil => F.pure(res) case HCons((h: Fiber[F, Any] @unchecked), t) if isJoin => - F.info(">>> Got fiber") >> - h.join.flatMap(x => F.info(s">>> Content: $x") >> joinOrCancel(t, x :: res)(isJoin)) + h.join.flatMap(x => joinOrCancel(t, x :: res)(isJoin)) case HCons((h: Fiber[F, Any] @unchecked), t) => h.cancel.flatMap(x => joinOrCancel(t, x :: res)(isJoin)) case HCons(h, t) => - F.error(s">>> Unexpected cons: ${h.toString}") >> joinOrCancel(t, res)(isJoin) + F.error(s"Unexpected result: ${h.toString}") >> joinOrCancel(t, res)(isJoin) } def cancelFibers(fibs: HList, err: Throwable = TransactionAborted): F[Unit] = diff --git a/modules/examples/src/main/scala/dev/profunktor/redis4cats/RedisTransactionsDemo.scala b/modules/examples/src/main/scala/dev/profunktor/redis4cats/RedisTransactionsDemo.scala index 2822dbba..c595bf59 100644 --- a/modules/examples/src/main/scala/dev/profunktor/redis4cats/RedisTransactionsDemo.scala +++ b/modules/examples/src/main/scala/dev/profunktor/redis4cats/RedisTransactionsDemo.scala @@ -75,7 +75,7 @@ object RedisTransactionsDemo extends LoggerIOApp { putStrLn("[Error] - Timeout") } - getters >> prog >> getters >> putStrLn("some more here") + getters >> prog >> getters >> putStrLn("keep doing stuff...") } }