blixit / event-sourcing

src/Store/InMemory/InMemoryEventPersister.php

Spacing +7 added lines, -7 removed lines

@@ -20,7 +20,7 @@ 
      */
     public function getByStream(StreamName $streamName, ?int $fromSequence = 0) : array
     {
-        return array_filter($this->events, static function (EventInterface $event) use (
+        return array_filter($this->events, static function(EventInterface $event) use (
             $streamName,
             $fromSequence
         ) {
@@ -40,7 +40,7 @@ 
      */
     public function find(EventMatcherInterface $eventMatcher) : array
     {
-        return array_filter($this->events, static function (EventInterface $event) use ($eventMatcher) {
+        return array_filter($this->events, static function(EventInterface $event) use ($eventMatcher) {
             $aggregateId    = $eventMatcher->getAggregateId();
             $aggregateClass = $eventMatcher->getAggregateClass();
             $fromSequence   = $eventMatcher->getSequence();
@@ -48,19 +48,19 @@ 
             $timestamp      = $eventMatcher->getTimestamp();
 
             $condition = true;
-            if (! empty($aggregateId)) {
+            if (!empty($aggregateId)) {
                 $condition = $condition && ($event->getAggregateId() === $aggregateId);
             }
-            if (! empty($aggregateClass)) {
+            if (!empty($aggregateClass)) {
                 $condition = $condition && ($event->getAggregateClass() === (string) $aggregateClass);
             }
-            if (! empty($fromSequence)) {
+            if (!empty($fromSequence)) {
                 $condition = $condition && ($event->getSequence() > $fromSequence);
             }
-            if (! empty($streamName)) {
+            if (!empty($streamName)) {
                 $condition = $condition && ($event->getStreamName() === (string) $streamName);
             }
-            if (! empty($timestamp)) {
+            if (!empty($timestamp)) {
                 $condition = $condition && ($event->getTimestamp() > $timestamp);
             }
             return $condition;

src/Stream/Stream.php

Spacing +2 added lines, -2 removed lines

@@ -46,7 +46,7 @@ 
         }
 
         if (empty($beforeEnqueue)) {
-            $beforeEnqueue = static function (EventInterface $event) : void {}; // phpcs:ignore
+            $beforeEnqueue = static function(EventInterface $event) : void {}; // phpcs:ignore
         }
 
         $this->queue         = new SplQueue();
@@ -81,7 +81,7 @@ 
         call_user_func($this->beforeEnqueue, $event);
         self::$eventAccessor->setStreamName($event, (string) $this->streamName);
 
-        if (! isset($this->lastEnqueuedSequenceNumber)) {
+        if (!isset($this->lastEnqueuedSequenceNumber)) {
             $this->lastEnqueuedSequenceNumber = $event->getSequence();
         }