Fix timeLimiter

event-band · Aug 28, 2017 · 297dfdf · 297dfdf
1 parent b94fefb
commit 297dfdf
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/src/EventBand/Processor/Control/TimeLimiter.php b/src/EventBand/Processor/Control/TimeLimiter.php
@@ -22,7 +22,7 @@ public function __construct($limit)
         }
         $this->limit = $limit;
 
-        $this->startTime = 0;
+        $this->initTimer();
     }
 
     public function initTimer()
@@ -32,11 +32,11 @@ public function initTimer()
 
     public function checkLimit(StoppableDispatchEvent $event)
     {
-        $now = time();
-        if ($this->startTime + $this->limit >= $now) {
+        $timeLeft = $this->startTime + $this->limit - time();
+        if ($timeLeft <= 0) {
             $event->stopDispatching();
             return 0;
         }
-        return (int) ($this->startTime + $this->limit - $now);
+        return $timeLeft;
     }
 }