Fixing duration on multiple passed check windows

Signed-off-by: Sebastian Peter <[email protected]>
ie3-institute · Oct 14, 2024 · 1a05221 · 1a05221
1 parent 3e8d49d
commit 1a05221
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/src/main/scala/edu/ie3/simona/scheduler/RuntimeNotifier.scala b/src/main/scala/edu/ie3/simona/scheduler/RuntimeNotifier.scala
@@ -111,10 +111,12 @@ final case class RuntimeNotifier(
         val completedWindows =
           (adjustedLastCheck + checkWindow) to completedTick by checkWindow
 
-        completedWindows.foreach { tick =>
-          notify(
-            CheckWindowPassed(tick, duration(lastCheckWindowTime, nowTime))
-          )
+        completedWindows.foldLeft(lastCheckWindowTime) {
+          case (lastTime, tick) =>
+            notify(
+              CheckWindowPassed(tick, duration(lastTime, nowTime))
+            )
+            None
         }
 
         completedWindows.lastOption