Align translator and decorator to fix replay bug

src/EventStoreIntegration/AggregateRootDecorator.php

@@ -78,11 +78,9 @@ public function fromHistory($arClass, \Iterator $aggregateChangedEvents)
      * @param AggregateRoot $aggregateRoot
      * @param Iterator $events
      */
-    public function applyStreamEvents(AggregateRoot $aggregateRoot, Iterator $events)
+    public function replayStreamEvents(AggregateRoot $aggregateRoot, Iterator $events)
     {
-        foreach ($events as $event) {
-            $aggregateRoot->apply($event);
-        }
+        $aggregateRoot->replay($events);
     }
 
     /**

src/EventStoreIntegration/AggregateTranslator.php

@@ -71,9 +71,9 @@ public function extractPendingStreamEvents($anEventSourcedAggregateRoot)
      * @param object $anEventSourcedAggregateRoot
      * @param Iterator $events
      */
-    public function applyStreamEvents($anEventSourcedAggregateRoot, Iterator $events)
+    public function replayStreamEvents($anEventSourcedAggregateRoot, Iterator $events)
     {
-        $this->getAggregateRootDecorator()->applyStreamEvents($anEventSourcedAggregateRoot, $events);
+        $this->getAggregateRootDecorator()->replayStreamEvents($anEventSourcedAggregateRoot, $events);
     }
 
     /**

tests/AggregateRootTest.php

@@ -38,15 +38,15 @@ public function it_applies_event_by_calling_appropriate_event_handler()
         //In between would be the process of persisting recorded events to an event stream
         //Only if this was successful the events can be applied to the aggregate root
         //We skip the persistence process here and apply the events directly
-        $decorator->applyStreamEvents($user, new \ArrayIterator($recordedEvents));
+        $decorator->replayStreamEvents($user, new \ArrayIterator($recordedEvents));
 
         $this->assertEquals('John', $user->name());
 
         $user->changeName('Max');
 
         $additionalRecordedEvents = $decorator->extractRecordedEvents($user);
 
-        $decorator->applyStreamEvents($user, new \ArrayIterator($additionalRecordedEvents));
+        $decorator->replayStreamEvents($user, new \ArrayIterator($additionalRecordedEvents));
 
         $this->assertEquals('Max', $user->name());
 
@@ -89,13 +89,13 @@ public function it_reconstructs_itself_from_history()
 
         $recordedEvents = $user->accessRecordedEvents();
 
-        AggregateRootDecorator::newInstance()->applyStreamEvents($user, new \ArrayIterator($recordedEvents));
+        AggregateRootDecorator::newInstance()->replayStreamEvents($user, new \ArrayIterator($recordedEvents));
 
         $user->changeName('Max');
 
         $additionalRecordedEvents = $user->accessRecordedEvents();
 
-        AggregateRootDecorator::newInstance()->applyStreamEvents($user, new \ArrayIterator($additionalRecordedEvents));
+        AggregateRootDecorator::newInstance()->replayStreamEvents($user, new \ArrayIterator($additionalRecordedEvents));
 
         $historyEvents = new \ArrayIterator(array_merge($recordedEvents, $additionalRecordedEvents));
 

tests/EventStoreIntegration/AggregateTranslatorTest.php

@@ -107,7 +107,7 @@ public function it_applies_stream_events(User $loadedUser)
         $newName = 'Jane Doe';
 
         $translator = new AggregateTranslator();
-        $translator->applyStreamEvents($loadedUser, new \ArrayIterator([UserNameChanged::occur($loadedUser->id(), [
+        $translator->replayStreamEvents($loadedUser, new \ArrayIterator([UserNameChanged::occur($loadedUser->id(), [
             'username' => $newName
         ])]));