Skip to content

Commit

Permalink
removing verbose logging
Browse files Browse the repository at this point in the history
  • Loading branch information
gvolpe committed May 4, 2020
1 parent 99e254a commit 61909c6
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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] =
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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...")
}
}

Expand Down

0 comments on commit 61909c6

Please sign in to comment.