Merge pull request #253 from peterneyens/use-realtime

Use Clock#realTime for Open#startedAt
davenverse · Apr 12, 2023 · 4f8f629 · 4f8f629
2 parents f19f896 + 10fcb29
commit 4f8f629
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/core/src/main/scala/io/chrisdavenport/circuit/CircuitBreaker.scala b/core/src/main/scala/io/chrisdavenport/circuit/CircuitBreaker.scala
@@ -594,7 +594,7 @@ object CircuitBreaker {
             case Open(_,_) => (ClosedZero, onClosed.attempt.void)
           }.flatten
         case Outcome.Errored(_) =>
-          Temporal[F].monotonic.map(_.toMillis).flatMap { now =>
+          Temporal[F].realTime.map(_.toMillis).flatMap { now =>
 
             ref.modify {
               case Closed(failures) =>
@@ -621,7 +621,7 @@ object CircuitBreaker {
     }
 
     def tryReset[A](open: Open, fa: F[A], poll: Poll[F]): F[A] = {
-      Temporal[F].monotonic.map(_.toMillis).flatMap { now =>
+      Temporal[F].realTime.map(_.toMillis).flatMap { now =>
         if (open.expiresAt >= now) onRejected >> F.raiseError(RejectedExecution(open))
         else {
           // This operation must succeed at setting backing to some other