@@ -28,7 +28,7 @@ discard block |
||
| 28 | 28 | /** |
| 29 | 29 | * Record a Domain Event |
| 30 | 30 | * |
| 31 | - * @param mixed $domainEvent |
|
| 31 | + * @param DomainEvent $domainEvent |
|
| 32 | 32 | */ |
| 33 | 33 | private function record($domainEvent) |
| 34 | 34 | { |
@@ -46,7 +46,7 @@ discard block |
||
| 46 | 46 | /** |
| 47 | 47 | * Apply a Domain Event to the aggregate |
| 48 | 48 | * |
| 49 | - * @param mixed $domainEvent |
|
| 49 | + * @param DomainEvent $domainEvent |
|
| 50 | 50 | */ |
| 51 | 51 | public function apply($domainEvent) |
| 52 | 52 | { |
@@ -73,7 +73,7 @@ discard block |
||
| 73 | 73 | |
| 74 | 74 | /** |
| 75 | 75 | * @param string $eventHandlerName |
| 76 | - * @param mixed $domainEventData |
|
| 76 | + * @param DomainEvent $domainEventData |
|
| 77 | 77 | * @throws DomainEventNotUnderstandableException |
| 78 | 78 | */ |
| 79 | 79 | private function applyRecursively($eventHandlerName, $domainEventData) |
@@ -68,7 +68,7 @@ discard block |
||
| 68 | 68 | */ |
| 69 | 69 | protected function domainEventStreamFromStoredEvents($eventStream) |
| 70 | 70 | { |
| 71 | - return $eventStream->map(function (StoredEvent $storedEvent) { |
|
| 71 | + return $eventStream->map(function(StoredEvent $storedEvent) { |
|
| 72 | 72 | $this->eventUpgrader->migrate($storedEvent); |
| 73 | 73 | return new DomainEvent( |
| 74 | 74 | $this->serializer->deserialize( |
@@ -117,7 +117,7 @@ discard block |
||
| 117 | 117 | */ |
| 118 | 118 | private function storedEventsFromEvents($streamId, $events) |
| 119 | 119 | { |
| 120 | - $storedEvents = array_map(function (DomainEvent $event) use ($streamId) { |
|
| 120 | + $storedEvents = array_map(function(DomainEvent $event) use ($streamId) { |
|
| 121 | 121 | return new StoredEvent( |
| 122 | 122 | $this->nextStoredEventId(), |
| 123 | 123 | $streamId, |