fixes issue with incrementing cursor too late

mannum · Jul 29, 2016 · 3eda2d9 · 3eda2d9
1 parent 851302d
commit 3eda2d9
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/Eventor/ServiceActivator.php b/src/Eventor/ServiceActivator.php
@@ -15,6 +15,8 @@ public function addActivator($eventName, callable $a)
     public function traverseStream(EventStreamInterface $s, EventStreamCursorInterface $cursor)
     {
         foreach ($s as $event) {
+            $cursor->increment();
+
             if (empty($this->activators[$event->getType()])) continue;
 
             try {
@@ -24,8 +26,6 @@ public function traverseStream(EventStreamInterface $s, EventStreamCursorInterfa
                 // @todo do something with exceptions here
                 var_dump($e->getMessage());
             }
-
-            $cursor->increment();
         }
     }