diff --git a/src/EventStore/TransactionManager.php b/src/EventStore/TransactionManager.php index 7fa3868..34e8c55 100644 --- a/src/EventStore/TransactionManager.php +++ b/src/EventStore/TransactionManager.php @@ -160,7 +160,8 @@ public function onFinalize(CommandDispatch $commandDispatch) */ public function onEventStoreCreateStream(ActionEvent $createEvent) { - $this->handleRecordedEvents($createEvent->getParam('stream')->streamEvents()); + $streamEvents = $createEvent->getParam('stream')->streamEvents(); + $this->handleRecordedEvents($streamEvents); } /** @@ -168,6 +169,7 @@ public function onEventStoreCreateStream(ActionEvent $createEvent) */ public function onEventStoreAppendToStream(ActionEvent $appendToStreamEvent) { - $this->handleRecordedEvents($appendToStreamEvent->getParam('streamEvents')); + $streamEvents = $appendToStreamEvent->getParam('streamEvents'); + $this->handleRecordedEvents($streamEvents); } -} \ No newline at end of file +}