blixit / event-sourcing

src/Stream/Stream.php

Spacing +2 added lines, -2 removed lines

@@ -44,7 +44,7 @@ 
         $this->queue = new SplQueue();
 
         if (empty($beforeEnqueue)) {
-            $beforeEnqueue = static function (EventInterface $event) : void {}; // phpcs:ignore
+            $beforeEnqueue = static function(EventInterface $event) : void {}; // phpcs:ignore
         }
 
         foreach ($events as $event) {
@@ -76,7 +76,7 @@ 
      */
     public function enqueue(EventInterface $event) : void
     {
-        if (! isset($this->lastEnqueuedSequenceNumber)) {
+        if (!isset($this->lastEnqueuedSequenceNumber)) {
             $this->lastEnqueuedSequenceNumber = $event->getSequence();
         }
 

src/Utils/Accessor.php

Spacing +2 added lines, -2 removed lines

@@ -25,7 +25,7 @@ 
      */
     protected function readProperty($object, string $property)
     {
-        return (function ($property) {
+        return (function($property) {
             return $this->$property;
         })->bindTo($object)->call($object, $property);
     }
@@ -36,7 +36,7 @@ 
      */
     protected function writeProperty(&$object, string $property, $value) : void
     {
-        (function ($property, $value) : void {
+        (function($property, $value) : void {
             $this->$property = $value;
         })->bindTo($object)->call($object, $property, $value);
     }

src/Store/EventStore.php

Spacing +4 added lines, -4 removed lines

@@ -87,7 +87,7 @@ 
         $stream = new ReadableStream(
             $streamName,
             $events,
-            static function (EventInterface $event) use ($beforeRead, $aggregate) : void {
+            static function(EventInterface $event) use ($beforeRead, $aggregate) : void {
                 $beforeRead($aggregate, $event);
             }
         );
@@ -143,7 +143,7 @@ 
         $stream = new StorableStream(
             $streamName,
             $aggregateRoot->getRecordedEvents(),
-            static function (EventInterface $event) use ($beforeWrite, $aggregateRoot) : void {
+            static function(EventInterface $event) use ($beforeWrite, $aggregateRoot) : void {
                 $beforeWrite($aggregateRoot, $event);
             }
         );
@@ -207,10 +207,10 @@ 
                 $event->getAggregateId()
             ));
         }
-        if (! empty($event->getSequence())) {
+        if (!empty($event->getSequence())) {
             throw new NonWritableEvent('Sequence number should be empty. Found: ' . $event->getSequence());
         }
-        if (! empty($event->getStreamName())) {
+        if (!empty($event->getStreamName())) {
             throw new NonWritableEvent('Stream name should be empty. Found: ' . $event->getStreamName());
         }
     }

src/Store/InMemory/InMemoryEventPersister.php

Spacing +1 added lines, -1 removed lines

@@ -19,7 +19,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
         ) {

src/Aggregate/AggregateAccessor.php

Spacing +1 added lines, -1 removed lines

@@ -31,7 +31,7 @@
         /** @var AggregateRoot $aggregateRoot */
         $events = $aggregateRoot->getRecordedEvents();
         $event  = array_shift($events);
-        if (! empty($event)) {
+        if (!empty($event)) {
             $this->writeProperty($aggregateRoot, 'recordedEvents', $events);
         }
         return $event;

src/Messaging/MessagingMiddleware.php

Spacing +3 added lines, -3 removed lines

@@ -27,7 +27,7 @@ 
     public function handle(MessageInterface $message) : void
     {
         $class = get_class($message);
-        if (! $this->supports($class)) {
+        if (!$this->supports($class)) {
             return;
         }
 
@@ -39,11 +39,11 @@ 
                 $locatedHandler($message);
                 continue;
             }
-            if (! is_array($locatedHandler)) {
+            if (!is_array($locatedHandler)) {
                 continue;
             }
             foreach ($locatedHandler as $handler) {
-                if (! is_callable($handler)) {
+                if (!is_callable($handler)) {
                     continue;
                 }
                 $handler($message);