Addressed drifting repeat alarms

CHANGELOG.md

@@ -0,0 +1,12 @@
+#### v0.1.2
+
+- Addressed execution time drift in repeating native reactor alarms
+
+#### v0.1.1
+
+- Addressed infinite recursion in repeating callbacks
+
+v0.1.0
+------
+
+- Initial tagged release

src/Alert/NativeReactor.php

@@ -110,18 +110,18 @@ class NativeReactor implements Reactor {
 
         foreach ($this->alarmOrder as $watcherId => $executionCutoff) {
             if ($executionCutoff <= $now) {
-                $this->doAlarmCallback($watcherId, $now);
+                $this->doAlarmCallback($watcherId);
             } else {
                 break;
             }
         }
     }
 
-    private function doAlarmCallback($watcherId, $now) {
+    private function doAlarmCallback($watcherId) {
         list($callback, $nextExecution, $interval, $isRepeating) = $this->alarms[$watcherId];
 
         if ($isRepeating) {
-            $nextExecution = $now + $interval;
+            $nextExecution += $interval;
             $this->alarms[$watcherId] = [$callback, $nextExecution, $interval, $isRepeating];
             $this->alarmOrder[$watcherId] = $nextExecution;
         } else {
@@ -130,7 +130,7 @@ class NativeReactor implements Reactor {
                 $this->alarmOrder[$watcherId]
             );
         }
-        
+
         $callback($watcherId);
     }