@@ -9,7 +9,7 @@ discard block |
||
| 9 | 9 | * file that was distributed with this source code. |
| 10 | 10 | */ |
| 11 | 11 | |
| 12 | -declare(strict_types=1); |
|
| 12 | +declare(strict_types = 1); |
|
| 13 | 13 | |
| 14 | 14 | namespace LIN3S\SharedKernel\Infrastructure\Persistence\Sql\Event; |
| 15 | 15 | |
@@ -68,7 +68,7 @@ discard block |
||
| 68 | 68 | return new Stream($name, $domainEventsCollection); |
| 69 | 69 | } |
| 70 | 70 | |
| 71 | - public function eventsSince(?\DateTimeInterface $since, int $offset = 0, int $limit = -1): array |
|
| 71 | + public function eventsSince(?\DateTimeInterface $since, int $offset = 0, int $limit = -1) : array |
|
| 72 | 72 | { |
| 73 | 73 | $since = null === $since ? 0 : $since->getTimestamp(); |
| 74 | 74 | $tableName = self::TABLE_NAME; |
@@ -94,7 +94,7 @@ discard block |
||
| 94 | 94 | $storedEvent = new StoredEvent( |
| 95 | 95 | $this->buildDomainEvent($storedEventRow), |
| 96 | 96 | StreamName::fromName($storedEventRow['stream_name']), |
| 97 | - new StreamVersion((int)$storedEventRow['stream_version']) |
|
| 97 | + new StreamVersion((int) $storedEventRow['stream_version']) |
|
| 98 | 98 | ); |
| 99 | 99 | $orderProperty = new \ReflectionProperty(StoredEvent::class, 'order'); |
| 100 | 100 | $orderProperty->setAccessible(true); |
@@ -118,7 +118,7 @@ discard block |
||
| 118 | 118 | |
| 119 | 119 | if ('occurredOn' === $property->getName()) { |
| 120 | 120 | $occurredOn = new \DateTimeImmutable(); |
| 121 | - $occurredOn->setTimestamp((int)$storedEventRow['occurred_on']); |
|
| 121 | + $occurredOn->setTimestamp((int) $storedEventRow['occurred_on']); |
|
| 122 | 122 | $property->setValue($domainEvent, $occurredOn); |
| 123 | 123 | continue; |
| 124 | 124 | } |