daikon-cqrs / message-bus

src/FromArrayTrait.php

Doc Comments +1 added lines, -1 removed lines

@@ -6,7 +6,7 @@
 {
     /**
      * @param array $arrayState
-     * @return MessageInterface
+     * @return FromArrayTrait
      */
     public static function fromArray(array $arrayState): MessageInterface
     {

Spacing +3 added lines, -3 removed lines

@@ -11,7 +11,7 @@ 
     public static function fromArray(array $arrayState): MessageInterface
     {
         $classReflection = new \ReflectionClass(static::class);
-        $classes = [ $classReflection ];
+        $classes = [$classReflection];
         $parent = $classReflection;
         while ($parent = $parent->getParentClass()) {
             $classes[] = $parent;
@@ -31,11 +31,11 @@ 
                 }
                 $factoryMethod = $matches[1];
                 if ($factoryMethod === '$ctor') {
-                    $valueFactories[$propName] = function ($value) use ($valueImplementor) {
+                    $valueFactories[$propName] = function($value) use ($valueImplementor) {
                         return new $valueImplementor($value);
                     };
                 } else {
-                    $valueFactories[$propName] = [ $valueImplementor, $factoryMethod ];
+                    $valueFactories[$propName] = [$valueImplementor, $factoryMethod];
                 }
             }
         }

src/MessageBus.php

Spacing +1 added lines, -1 removed lines

@@ -85,7 +85,7 @@
     {
         return array_reduce(
             $this->metadataEnrichers->toArray(),
-            function (Metadata $metadata, MetadataEnricherInterface $metadataEnricher) {
+            function(Metadata $metadata, MetadataEnricherInterface $metadataEnricher) {
                 return $metadataEnricher->enrich($metadata);
             },
             $metadata

src/ToArrayTrait.php

Spacing +3 added lines, -3 removed lines

@@ -14,13 +14,13 @@
         $classProps = $reflectionClass->getProperties();
         foreach ($classProps as $prop) {
             $propName = $prop->getName();
-            $propGetter = [ $this, "get".ucfirst($propName) ];
+            $propGetter = [$this, "get".ucfirst($propName)];
             if (!is_callable($propGetter)) {
                 continue;
             }
             $propVal = call_user_func($propGetter);
-            $toNative = [ $propVal, "toNative" ];
-            $toArray = [ $propVal, "toArray" ];
+            $toNative = [$propVal, "toNative"];
+            $toArray = [$propVal, "toArray"];
             if (is_callable($toNative)) {
                 $data[$propName] = call_user_func($toNative);
             } elseif (is_callable($toArray)) {

src/Channel/Subscription/SubscriptionMap.php

Spacing +1 added lines, -1 removed lines

@@ -13,7 +13,7 @@
      */
     public function __construct(array $subscriptions = [])
     {
-        $this->init(array_reduce($subscriptions, function (array $carry, SubscriptionInterface $subscription) {
+        $this->init(array_reduce($subscriptions, function(array $carry, SubscriptionInterface $subscription) {
             $carry[$subscription->getKey()] = $subscription; // enforce consistent channel keys
             return $carry;
         }, []), SubscriptionInterface::CLASS);

src/Channel/Subscription/Subscription.php

Spacing +2 added lines, -2 removed lines

@@ -58,7 +58,7 @@ 
         $this->messageHandlers = $messageHandlers;
         $this->guard = $guard;
         $this->metadataEnrichers = ($metadataEnrichers ?? new MetadataEnricherList)
-            ->push(new CallbackMetadataEnricher(function (Metadata $metadata): Metadata {
+            ->push(new CallbackMetadataEnricher(function(Metadata $metadata): Metadata {
                 return $metadata->with(self::METADATA_KEY, $this->getKey());
             }));
     }
@@ -106,7 +106,7 @@ 
     {
         return $envelope->withMetadata(array_reduce(
             $this->metadataEnrichers->toArray(),
-            function (Metadata $metadata, MetadataEnricherInterface $metadataEnricher) {
+            function(Metadata $metadata, MetadataEnricherInterface $metadataEnricher) {
                 return $metadataEnricher->enrich($metadata);
             },
             $envelope->getMetadata()

src/Channel/ChannelMap.php

Spacing +1 added lines, -1 removed lines

@@ -13,7 +13,7 @@
      */
     public function __construct(array $channels = [])
     {
-        $this->init(array_reduce($channels, function (array $carry, ChannelInterface $channel) {
+        $this->init(array_reduce($channels, function(array $carry, ChannelInterface $channel) {
             $carry[$channel->getKey()] = $channel; // enforce consistent channel keys
             return $carry;
         }, []), ChannelInterface::CLASS);

src/Channel/Channel.php

Spacing +2 added lines, -2 removed lines

@@ -51,7 +51,7 @@ 
         $this->subscriptions = $subscriptions;
         $this->guard = $guard;
         $this->metadataEnrichers = ($metadataEnrichers ?? new MetadataEnricherList)
-            ->push(new CallbackMetadataEnricher(function (Metadata $metadata): Metadata {
+            ->push(new CallbackMetadataEnricher(function(Metadata $metadata): Metadata {
                 return $metadata->with(self::METADATA_KEY, $this->getKey());
             }));
     }
@@ -111,7 +111,7 @@ 
     {
         return $envelope->withMetadata(array_reduce(
             $this->metadataEnrichers->toArray(),
-            function (Metadata $metadata, MetadataEnricherInterface $metadataEnricher) {
+            function(Metadata $metadata, MetadataEnricherInterface $metadataEnricher) {
                 return $metadataEnricher->enrich($metadata);
             },
             $envelope->getMetadata()