fix for Infinity delays in Schedule (#2773)

Effect-TS · May 19, 2024 · 596aaea · 596aaea
1 parent 9196fff
commit 596aaea
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 2 deletions.
diff --git a/.changeset/twelve-balloons-pay.md b/.changeset/twelve-balloons-pay.md
@@ -0,0 +1,5 @@
+---
+"effect": patch
+---
+
+fix for Infinity delays in Schedule
diff --git a/packages/effect/src/internal/schedule.ts b/packages/effect/src/internal/schedule.ts
@@ -672,7 +672,7 @@ export const exponential = (
 ): Schedule.Schedule<Duration.Duration> => {
   const base = Duration.decode(baseInput)
   return delayedSchedule(
-    map(forever, (i) => Duration.times(base, Math.min(Number.MAX_SAFE_INTEGER, Math.pow(factor, i))))
+    map(forever, (i) => Duration.times(base, Math.pow(factor, i)))
   )
 }
 
@@ -1060,7 +1060,7 @@ export const modifyDelayEffect = dual<
           const oldStart = Intervals.start(intervals)
           const newStart = now + Duration.toMillis(duration)
           const delta = newStart - oldStart
-          const newEnd = Math.min(Math.max(0, Intervals.end(intervals) + delta), Number.MAX_SAFE_INTEGER)
+          const newEnd = Math.max(0, Intervals.end(intervals) + delta)
           const newInterval = Interval.make(newStart, newEnd)
           return [state, out, ScheduleDecision.continueWith(newInterval)] as const
         })